       @_incoming = null
       @emit 'error', exception
 
-  _processRequest: () ->
+  _processRequest: ->
     # Process the request now if the socket is open and
     # we aren't already handling a response
     if @readyState is 'open' and !@_incoming

    # Initialize the response netstring parser
    @_initResponseParser()

  _initResponseParser: () ->
    # Initialize a Netstring stream parser
    nsStream = new ns.Stream this


      # Try to reconnect and try again soon
      @reconnect()

  _finishRequest: ->
    @_outgoing.shift()

    res = @_incoming
