bidiStreamingRpcFunction

fun <RequestT, ResponseT> bidiStreamingRpcFunction(channel: Channel, method: MethodDescriptor<RequestT, ResponseT>, callOptions: CallOptions = CallOptions.DEFAULT, headers: suspend () -> Metadata = { GrpcMetadata() }): (Flow<RequestT>) -> Flow<ResponseT>
Content copied to clipboard

Returns a function object representing a bidirectional streaming RPC.

The input headers may be asynchronously formed. headers will be called each time the returned RPC is called - the headers are not cached.

Sources

jvm source
Link copied to clipboard