code: 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);
  }
docs: Public {{{1