()
| 94 | |
| 95 | @pytest.mark.skipif(sys.version_info < (3, 11), reason="ExceptionGroup not available") |
| 96 | async def test_dispatch(): |
| 97 | events, expected_model = make_events_and_expected_model() |
| 98 | changes, send, recv = make_send_recv_callbacks(events) |
| 99 | with pytest.raises(ExceptionGroup): |
| 100 | await asyncio.wait_for(serve_layout(Layout(Counter()), send, recv), 1) |
| 101 | assert_changes_produce_expected_model(changes, expected_model) |
| 102 | |
| 103 | |
| 104 | async def test_dispatcher_handles_more_than_one_event_at_a_time(): |
nothing calls this directly
no test coverage detected