Lines Matching refs:streams
74436 function popCallback(streams) {
74437 if (!streams.length) return noop;
74438 if (typeof streams[streams.length - 1] !== 'function') return noop;
74439 return streams.pop();
74443 for (var _len = arguments.length, streams = new Array(_len), _key = 0; _key < _len; _key++) {
74444 streams[_key] = arguments[_key];
74447 var callback = popCallback(streams);
74448 if (Array.isArray(streams[0])) streams = streams[0];
74450 if (streams.length < 2) {
74455 var destroys = streams.map(function (stream, i) {
74456 var reading = i < streams.length - 1;
74466 return streams.reduce(pipe);