def _read_bytes(self, size, callback):
        try:
            self.stream.read_bytes(size, callback)
        except __HOLE__:
            self.close()
            self.trigger(
                event.ERROR,
                conn=self,
                error=protocol.ConnectionClosedError('Stream is closed'),
            )
dataset/ETHPy150Open nsqio/pynsq/nsq/async.py/AsyncConn._read_bytes