()
| 357 | |
| 358 | |
| 359 | def test_ZeroMqQueue_sync_async(): |
| 360 | # sync send, async recv |
| 361 | push_pipe = ZeroMqQueue(is_async=False, is_server=True) |
| 362 | |
| 363 | pool = ProcessPoolExecutor(max_workers=1) |
| 364 | res = pool.submit(_ZeroMqQueue_sync_sync_task, push_pipe.address) |
| 365 | |
| 366 | for i in range(10): |
| 367 | print(f"put: {i}") |
| 368 | push_pipe.put(i) |
| 369 | |
| 370 | assert res.result() == 45 |
| 371 | pool.shutdown() |
| 372 | push_pipe.close() |
| 373 | |
| 374 | |
| 375 | def _ZeroMqQueue_serialization_complicated_dataclass(addr: str, |