Test interrupted completion.
(self)
| 225 | assert state.end_time is not None |
| 226 | |
| 227 | def test_complete_interrupted(self): |
| 228 | """Test interrupted completion.""" |
| 229 | state = StreamingState() |
| 230 | state.add_chunk(StreamingChunk(content="Test")) |
| 231 | |
| 232 | state.complete(interrupted=True) |
| 233 | |
| 234 | assert state.phase == StreamingPhase.INTERRUPTED |
| 235 | assert state.interrupted |
| 236 | assert state.is_complete |
| 237 | |
| 238 | def test_mark_error(self): |
| 239 | """Test error state.""" |
nothing calls this directly
no test coverage detected