(self, *args, **kwargs)
| 21 | self._socket_server.listen(1) |
| 22 | |
| 23 | def recv(self, *args, **kwargs): |
| 24 | if self._sock_for_reader_thread is None: |
| 25 | sock, _addr = self._socket_server.accept() |
| 26 | self._sock_for_reader_thread = sock |
| 27 | return self._sock_for_reader_thread.recv(*args, **kwargs) |
| 28 | |
| 29 | def put(self, msg): |
| 30 | if not isinstance(msg, bytes): |
no outgoing calls
no test coverage detected