index.js
function _bindReadable(pointer, stream, serializer) {
  stream.on('data', (data) => {
    serializer.write(jsonrpc.notification(pointer, [data]));
  });
  stream.on('end', () => {
    serializer.write(jsonrpc.notification(pointer, [null]));
  });
  stream.on('error', () => {
    serializer.write(jsonrpc.notification(pointer, [null]));
  });
}
function _bindReadable(pointer, stream, serializer) {
  stream.on('data', (data) => {
    serializer.write(jsonrpc.notification(pointer, [data]));
  });
  stream.on('end', () => {
    serializer.write(jsonrpc.notification(pointer, [null]));
  });
  stream.on('error', () => {
    serializer.write(jsonrpc.notification(pointer, [null]));
  });
}
function _bindReadable ( pointer , stream , serializer ) { stream . on ( 'data' , ( data ) => { serializer . write ( jsonrpc . notification ( pointer , [ data ] ) ) ; } ) ; stream . on ( 'end' , ( ) => { serializer . write ( jsonrpc . notification ( pointer , [ null ] ) ) ; } ) ; stream . on ( 'error' , ( ) => { serializer . write ( jsonrpc . notification ( pointer , [ null ] ) ) ; } ) ; }
Binds to readable stream events and write messages to the given serializer
@param {string} pointer
@param {object} stream
@param {object} serializer
Binds to readable stream events and write messages to the given serializer