v0.2.0

Added

• Emitting error via callback (done or next) by passing Error object.

  var pipeline = require('piperline').create();
  pipeline
      .pipe(function(data, next) {
          next(data);
      })
      .pipe(function(data, next, done) {
          done(new Error());
      })
      .on('error', function(err) {
        console.log(err); // Error
      })
      .run(0);

• Added callback to run method

  var pipeline = require('piperline').create();

  pipeline
    .pipe(task1)
    .pipe(task2)
    .pipe(task3)
    .run(data, function(err, result) {
      if (err) {
        pipeline.run(1);
      }
    });

or

  var pipeline = require('piperline').create();

  pipeline
    .pipe(task1)
    .pipe(task2)
    .pipe(task3)
    .run(function(err, result) {
      if (err) {
        pipeline.run(1);
      }
    });

The difference between events, that this callback passed to run method is called only once when the pipeline work is done.