                 
         # outgoing -> Stream
         @parser.on "frame", (frame) =>
+            @_pingData()
             @emit "frame", frame
 
             # -- queue up frames until we get to @emitDuration -- #

        super()
        
        @emitDuration  = 0.5
    
        # 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

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