bidi Streaming Rpc
fun <RequestT, ResponseT> bidiStreamingRpc(channel: Channel, method: MethodDescriptor<RequestT, ResponseT>, requests: Flow<RequestT>, callOptions: CallOptions = CallOptions.DEFAULT, headers: Metadata = GrpcMetadata()): Flow<ResponseT>
Content copied to clipboard
Returns a Flow which launches the specified bidirectional-streaming RPC, collecting the requests flow, sending them to the server, and emitting the responses.
Cancelling collection of the flow cancels the RPC upstream and collection of the requests. For example, if responses.take(2).toList()
is executed, the RPC will be cancelled after the first two responses are returned.
Sources
jvm source
Link copied to clipboard