Channel with capacity 1 maintains FIFO order.
()
| 30 | |
| 31 | |
| 32 | def test_channel_capacity_1_fifo() -> None: |
| 33 | """Channel with capacity 1 maintains FIFO order.""" |
| 34 | c = chan(1) |
| 35 | |
| 36 | for i in range(5): |
| 37 | buf = rt.asarray(np.array([float(i)])) |
| 38 | c.send(buf) |
| 39 | received = c.recv() |
| 40 | assert received.scalar() == float(i) |
| 41 | |
| 42 | |
| 43 | def test_par_threshold_boundary() -> None: |