

@handler('read', channel='source')
def _on_source_read(self, sock, data):
    'Explicitly defined Read Event Handler\n\n        This evens is triggered by the underlying TCPServer Component when\n        a connected client has some data ready to be processed.\n\n        Here we simply fire a cooresponding write event to the cooresponding\n        matching client which we lookup using the socket object as the key\n        to determinte the unique id.\n        '
    client = self._clients[sock]
    self.fire(write(data), client.channel)

dataset/ETHPy150Open circuits/circuits/examples/portforward.py PortForwarder._on_source_read/original