(self)
| 6 | |
| 7 | class TestChannel: |
| 8 | def test_send_recv(self) -> None: |
| 9 | c = rt.chan(10) |
| 10 | c.send(rt.asarray(np.array([1.0, 2.0, 3.0]))) |
| 11 | buf = c.recv() |
| 12 | np.testing.assert_array_equal(buf.numpy(), [1.0, 2.0, 3.0]) |
| 13 | |
| 14 | def test_multiple_send_recv(self) -> None: |
| 15 | c = rt.chan(10) |