Highland Errors To

Redirect errors in a highland stream.

Install

npm install highland-errors-to

Usage

var _ = require('highland'),
    errorsTo = require('highland-errors-to'),
    things,
    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);
});

var things = errorsTo(stream);
errorStream = things.errors;
stream = things.stream;

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

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

stream.resume();