lib/ws/read.js
function init(cb) {  // {{{2
  if (typeof cb !== 'function') {
    throw O.log.error(this, 'Callback must be a function', cb);
  }

  this.stream = new Readable();
  this.stream._read = O._.noop;
  this.stream.on('error', onError.bind(this));

  cb(null, this.stream);
}
function init(cb) {  // {{{2
  if (typeof cb !== 'function') {
    throw O.log.error(this, 'Callback must be a function', cb);
  }

  this.stream = new Readable();
  this.stream._read = O._.noop;
  this.stream.on('error', onError.bind(this));

  cb(null, this.stream);
}
function init ( cb ) { // {{{2 if ( typeof cb !== 'function' ) { throw O . log . error ( this , 'Callback must be a function' , cb ) ; } this . stream = new Readable ( ) ; this . stream . _read = O . _ . noop ; this . stream . on ( 'error' , onError . bind ( this ) ) ; cb ( null , this . stream ) ; }
Public {{{1
Public {{{ 1