Method stream_events

tests/fastapi/streaming_app.py:28–30 · view source on GitHub ↗

(self)

Source from the content-addressed store, hash-verified

26	self.result = result
27
28	async def stream_events(self) -> AsyncIterator[str]:
29	async for event in self.result.stream_events():
30	yield f"{event.type}\n\n"

streamFunction · 0.95

test_streamed_run_hooks_with_llmFunction · 0.45

test_streamed_run_hooks_llm_errorFunction · 0.45

test_run_hooks_receives_turn_input_streamedFunction · 0.45

test_streamed_run_hooks_count_tool_and_handoff_invocationsFunction · 0.45

test_input_guardrail_results_follow_completion_orderFunction · 0.45

test_run_streamed_input_guardrail_timing_is_consistentFunction · 0.45

run_onceFunction · 0.45

test_run_streamed_input_guardrail_tripwire_raisesFunction · 0.45

test_parent_span_and_trace_finish_after_slow_input_guardrailFunction · 0.45

test_parent_span_and_trace_finish_after_slow_modelFunction · 0.45

test_single_turn_model_errorFunction · 0.45

no outgoing calls

test_streamed_run_hooks_with_llmFunction · 0.36

test_streamed_run_hooks_llm_errorFunction · 0.36

test_run_hooks_receives_turn_input_streamedFunction · 0.36

test_streamed_run_hooks_count_tool_and_handoff_invocationsFunction · 0.36

test_input_guardrail_results_follow_completion_orderFunction · 0.36

test_run_streamed_input_guardrail_timing_is_consistentFunction · 0.36

run_onceFunction · 0.36

test_run_streamed_input_guardrail_tripwire_raisesFunction · 0.36

test_parent_span_and_trace_finish_after_slow_input_guardrailFunction · 0.36

test_parent_span_and_trace_finish_after_slow_modelFunction · 0.36

test_single_turn_model_errorFunction · 0.36

test_multi_turn_no_handoffsFunction · 0.36