anchor.diff:            '${EventFormat.supportedFormats.join(', ')}'));
       }
   
  -    return this._subscribeAndSendCommand(
  +    return _subscribeAndSendCommand(
           'myevents $uuid', new Duration(seconds: timeoutSeconds));
     }
   
  
positive.code:   /**
     * Perform a hard socket disconnect.
     */
    Future disconnect() => this._socket.close();
  
    /**
     * Dispatches a packet by injecting it into the appropriate stream.
     */
    void _dispatch(Packet packet) {
      if (packet.isEvent) {
        this._eventStream.add(new Event.fromPacket(packet));
      } else if (packet.isRequest) {
        this._requestStream.add(new Request.fromPacket(packet));
      } else if (packet.isReply) {
        Completer<Reply> completer = this.replyQueue.removeFirst();
        if (!completer.isCompleted) {
          completer.complete(new Reply.fromPacket(packet));
        } else {
          this.log.info('Discarding packet for timed out command.');
        }
      } else if (packet.isResponse) {
        Completer<Response> completer = this.apiJobQueue.removeFirst();
        if (!completer.isCompleted) {
          completer.complete(new Response.fromPacketBody(packet.content.trim()));
        } else {
          this.log.info('Discarding packet for timed out api command.');
        }
      } else {
        this.log.severe('Discarding unknown packet type ${packet.contentType}');
      }
    }
  }
  
negative.code:    * to the channel has been received by the socket client.
     */
    Future<Reply> linger({int timeoutSeconds: 10}) =>
        _subscribeAndSendCommand('linger', new Duration(seconds: timeoutSeconds));
  
    /**
     * Disable socket lingering. See linger above.
     */
    Future<Reply> nolinger({int timeoutSeconds: 10}) => _subscribeAndSendCommand(
        'nolinger', new Duration(seconds: timeoutSeconds));
  
    /**
     * Subscribe the socket to [events], which will be pumped into the
  