@handler("read", channel="source")
    def _on_source_read(self, sock, data):

        client = self._clients[sock]
        self.fire(write(data), client.channel)
Explicitly defined Read Event Handler
dataset/ETHPy150Open circuits/circuits/examples/portforward.py/PortForwarder._on_source_read