docs: function(params, cb) {
      if (_.isString(params)) {
        params = { topic: params };
      }
  
      assert(params.topic);
      assert(cb);
      _closing = false;
  
      if (!params.maxWait) { params.maxWait = _options.maxWait; }
      if (!params.minBytes) { params.minBytes = _options.minBytes; }
  
      _initiate(params, function(err, topic) {
        if (err) { cb(err, null); return; }
        _poll(topic, null, cb);
      });
    }