bidiStreamingRpc

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