anchor.diff:      connectionLogger.info("[${connId}] Trying to connect to ${host}:${port} [attempt ${_connectionAttempt + 1}/${_poolConfig.maxConnectionAttempts}]");
       Socket.connect(host, port).then((Socket s) {
         _socket = s;
  +      _socketFlushed = new Future.value(true);
   
         // Initialize our writer pool and set the reservation timeout
         _reservedFrameWriters.clear();
  
positive.code:   Map<int, Completer> _pendingResponses;
    Completer _connected;
    Completer _drained;
  
    Connection(String this.connId, String this.host, int this.port, {PoolConfiguration config, String this.defaultKeyspace}) {
      // If no config is specified, use the default one
  
negative.code:   Future _writeMessage(RequestMessage message) {
  
      Completer reply = new Completer();
      // Make sure we have flushed our socket data and then
      // block till we get back a frame writer
      _socketFlushed
      .then( (_) => _frameWriterPool.reserve())
      .then((FrameWriter writer) {
        _reservedFrameWriters[ writer.getStreamId()] = writer;
        _pendingResponses[ writer.getStreamId() ] = reply;
        connectionLogger.fine("[${connId}] [stream #${writer.getStreamId()}] Sending message of type ${Opcode.nameOf(message.opcode)} (${message.opcode}) ${message}");
        writer.writeMessage(message, _socket, compression : _poolConfig.compression);
        _socketFlushed = _socket.flush();
        return _socketFlushed;
      })
      .catchError((e, trace) {
        // Wrap SocketExceptions
  