(self, obj, *, unbounditems=None)
| 231 | break |
| 232 | |
| 233 | def put_nowait(self, obj, *, unbounditems=None): |
| 234 | if unbounditems is None: |
| 235 | unboundop = -1 |
| 236 | else: |
| 237 | unboundop, = _serialize_unbound(unbounditems) |
| 238 | _queues.put(self._id, obj, unboundop) |
| 239 | |
| 240 | def get(self, block=True, timeout=None, *, |
| 241 | _delay=10 / 1000, # 10 milliseconds |
no test coverage detected