temporalio.contrib.google_genai._temporal_interactions._TemporalInteractionAsyncStream

class documentation

class _TemporalInteractionAsyncStream: (source)

Constructor: _TemporalInteractionAsyncStream(events)

View In Hierarchy

Async stream over interaction events already drained in an activity.

Presents the same async for / async with / close() surface as the SDK's streaming response, but iterates an in-memory event list drained inside the activity (there is no httpx response or client on the workflow side), rehydrating each event back into its typed form on iteration.

Async Method __aenter__ Undocumented
Async Method __aexit__ Undocumented
Method __aiter__ Undocumented
Method __init__ Undocumented
Async Method close No-op — the upstream stream was drained inside the activity.
Async Method _iter Undocumented
Instance Variable _events Undocumented
async def __aenter__(self) -> _TemporalInteractionAsyncStream: (source)

Undocumented

async def __aexit__(self, exc_type: type[BaseException] | None, exc: BaseException | None, exc_tb: TracebackType | None): (source)

Undocumented

def __aiter__(self) -> AsyncIterator[InteractionSSEEvent]: (source)

Undocumented

def __init__(self, events: list[dict[str, Any]]): (source)

Undocumented

async def close(self): (source)

No-op — the upstream stream was drained inside the activity.

async def _iter(self) -> AsyncIterator[InteractionSSEEvent]: (source)

Undocumented

_events = (source)

Undocumented