Почему эта функция потока приводит к ошибке?

Question

Я написал функцию, которая будет подключаться к ней, и будет записывать предоставленные аргументы в консоль.

function sconsole() { 
    var stream = new Stream.Transform({objectMode: true}), 
     foo = [].slice.call(arguments); 

    stream._transform = function (data, encoding, callback) { 
     console.log.apply(null, foo); 
     callback(null, data); 
    }; 

    return stream; 
} 

Пример использования:

stream 
    .pipe(sconsole('foo')) 
    .pipe(...); 

Но при использовании в конечном положении последовательности труб вызовов, это вызывает следующее сообщение об ошибке:

TypeError: Invalid non-string/buffer chunk 

Почему?

Answer 1

Вы не можете смешивать/труба objectMode и не objectMode потоки вместе, потому что они работают с разными типами данных.

Однако, если у вас есть узел v0.12 + или io.js, вы мог использовать что-то вроде readableObjectMode: true, который устанавливает читаемую сторону вашего преобразования потока для чтения объектов, но писать байты в обычном режиме. Вы можете сделать что-то подобное по-другому с writableObjectMode: true (objectMode: true эквивалентно установке обоих этих свойств на true). Таким образом, вы можете конвертировать один тип потока в другой.