(self, dir, data, logger=log.debug)
| 159 | log.reraise_exception("Error while closing {0} message stream", self.name) |
| 160 | |
| 161 | def _log_message(self, dir, data, logger=log.debug): |
| 162 | return logger("{0} {1} {2}", self.name, dir, data) |
| 163 | |
| 164 | def _read_line(self, reader): |
| 165 | line = b"" |
no outgoing calls
no test coverage detected