(self, obj)
| 387 | return _ForkingPickler.loads(res) |
| 388 | |
| 389 | def put(self, obj): |
| 390 | # serialize the data before acquiring the lock |
| 391 | obj = _ForkingPickler.dumps(obj) |
| 392 | if self._wlock is None: |
| 393 | # writes to a message oriented win32 pipe are atomic |
| 394 | self._writer.send_bytes(obj) |
| 395 | else: |
| 396 | with self._wlock: |
| 397 | self._writer.send_bytes(obj) |
| 398 | |
| 399 | __class_getitem__ = classmethod(types.GenericAlias) |
nothing calls this directly
no test coverage detected