__init__#

gRPCInputStream.__init__(request_iterator: AsyncIterator[T], *, cancel_event: Event | None = None)[source]#

Initialize the gRPCInputStream.

Parameters:

  • request_iterator (AsyncIterator[T]) – The underlying async iterator of request messages.

  • cancel_event (Event | None) – Optional event that signals cancellation from the client.