Skip to main content
function GrpcStream.cancelled 
def GrpcStream.cancelled() -> bool
Returns True if the client has cancelled the originating call. Same signal as rpc.cancelled() from the call this stream came from. function GrpcStream.complete 
def GrpcStream.complete(
*,
status: typing.Any = …
) -> None
Close the stream. No-arg = success; status = = error. Subsequent push calls after complete raise. function GrpcStream.push 
def GrpcStream.push(msg: typing.Any) -> None
Push one message to the response stream. Runtime-typechecked against the RPC’s response type; mismatched types raise. Blocks on backpressure. After the client has cancelled, push is best-effort (the message is dropped, no error raised) — producer loops should poll stream.cancelled() to bail out.