diff --git a/mitogen/core.py b/mitogen/core.py index 20add07b..29555ea6 100644 --- a/mitogen/core.py +++ b/mitogen/core.py @@ -1085,7 +1085,7 @@ class IoLogger(BasicStream): def on_receive(self, broker): _vv and IOLOG.debug('%r.on_receive()', self) - buf = os.read(self.receive_side.fd, CHUNK_SIZE) + buf = self.receive_side.read() if not buf: return self.on_disconnect(broker)