     #----------
     
     disconnect: ->
-        @res.end()
+        @sock.end()
         @connected = false
         @emit "disconnect"
            # source has gone away
            @emit "disconnect"
            @sock.end()

        # return with success
        @connected = true
    

        super()
        
        @emitDuration  = 0.5
        
        # -- Alert if data stops flowing -- #
        
        # creates a sort of dead mans switch that we use to kill the connection 
        # if it stops sending data
        @_pingData = _u.debounce => 
            # data has stopped flowing. kill the connection.
            @log.info "Source data stopped flowing.  Killing connection."
            @disconnect()
            
        , 30*1000
    
        # data is going to start streaming in as data on req. We need to pipe 
        # it into a parser to turn it into frames, headers, etc
