anchor.diff:                completer.completeError(new TimeoutException('Failed to get response to command $command')));
      }
   
  +  /**
  +   * Perform a graceful shutdown.
  +   * Not yet implemented.
  +   */
     void _shutdown() => throw new StateError('Not implemented');
   
  +  /**
  +   * 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));
  
positive.code: part of esl;
  
  abstract class EventFormat {
    static String Plain = "plain";
    static String Json  = "json";
    static String Xml   = "xml";
  
    static List<String> supportedFormats = [Json];
  }
  
  class Connection {
  
    final Logger log = new Logger (libraryName);
  
negative.code:    return this._sendSerializedCommand (command, completer, timeout);
    }
  
    /**
     * Send pre-serialized command.
     */
    Future _sendSerializedCommand (String command, Completer completer, Duration timeout) {
        /// Write the command to socket.
        /// XXX: Figure out if writeln will ever throw an exception.
  