Return the next object from the channel. If the queue is empty then raise QueueEmpty. Otherwise this is the same as get().
(self)
| 270 | return obj |
| 271 | |
| 272 | def get_nowait(self): |
| 273 | """Return the next object from the channel. |
| 274 | |
| 275 | If the queue is empty then raise QueueEmpty. Otherwise this |
| 276 | is the same as get(). |
| 277 | """ |
| 278 | try: |
| 279 | obj, unboundop = _queues.get(self._id) |
| 280 | except QueueEmpty: |
| 281 | raise # re-raise |
| 282 | if unboundop is not None: |
| 283 | assert obj is None, repr(obj) |
| 284 | return _resolve_unbound(unboundop) |
| 285 | return obj |
| 286 | |
| 287 | |
| 288 | _queues._register_heap_types(Queue, QueueEmpty, QueueFull) |
no test coverage detected