Test starting streaming creates state.
(self, manager)
| 27 | |
| 28 | @pytest.mark.asyncio |
| 29 | async def test_start_streaming(self, manager): |
| 30 | """Test starting streaming creates state.""" |
| 31 | await manager.start_streaming() |
| 32 | |
| 33 | assert manager.streaming_state is not None |
| 34 | assert manager.streaming_state.phase == StreamingPhase.INITIALIZING |
| 35 | assert manager.is_streaming |
| 36 | assert manager.is_busy |
| 37 | |
| 38 | # Cleanup |
| 39 | await manager.stop_streaming() |
| 40 | |
| 41 | @pytest.mark.asyncio |
| 42 | async def test_add_chunk_creates_state_if_needed(self, manager): |
nothing calls this directly
no test coverage detected