geronimo-iia /
async-rx
| Total Complexity | 1 |
| Total Lines | 12 |
| Duplicated Lines | 0 % |
| Changes | 0 | ||
| 1 | from async_rx.protocol import connectable_observable_handler |
||
| 2 | |||
| 3 | |||
| 4 | def test_connectable_observable_handler(): |
||
| 5 | async def dummy(): |
||
| 6 | pass |
||
| 7 | |||
| 8 | handler = connectable_observable_handler(on_connect=dummy, on_disconnect=dummy) |
||
| 9 | assert handler |
||
| 10 | assert handler.on_connect |
||
| 11 | assert handler.on_disconnect |
||
| 12 |
