highland-errors-to

Highland Errors To

Redirect errors in a highland stream.

Install

npm install highland-errors-to

Usage

var _ = require('highland'),
    errorsTo = require('highland-errors-to'),
    stream,
    errorStream;

stream = _(function(push, next) {
  push(null, 'hello');
  push(new Error('first error'));
  push(null, 'everyone');
  push(new Error('second error'));
  push(null, _.nil);
});

errorStream = _();

stream = stream.consume(errorsTo(errorStream));

stream
  .errors(function(error, push) {
    // never called, all errors are redirected!
  });

errorStream
  .errors(function(error, push) {
    // called for every error in stream
  });

stream.resume();
errorStream.resume();