             # source has gone away
             @emit "disconnect"
             @sock.end()
-
+        
         # return with success
         @connected = true
     

                
        # outgoing -> Stream
        @parser.on "frame", (frame) =>
            @emit "frame", frame

            # -- queue up frames until we get to @emitDuration -- #

        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
