Sha256: 7f33eabc4807fd1094a7f6263f28180bafdf93282575a0bfee38b268000b1cc6
Contents?: true
Size: 556 Bytes
Versions: 119
Compression:
Stored size: 556 Bytes
Contents
var common = require('../common');
var assert = common.assert;
var fake = common.fake.create();
var DelayedStream = common.DelayedStream;
var Stream = require('stream').Stream;
(function testHandleSourceErrors() {
var source = new Stream();
var delayedStream = DelayedStream.create(source, {pauseStream: false});
// We deal with this by attaching a no-op listener to 'error' on the source
// when creating a new DelayedStream. This way error events on the source
// won't throw.
source.emit('error', new Error('something went wrong'));
})();
Version data entries
119 entries across 105 versions & 6 rubygems