stub/io.grpc.kotlin/ServerCalls

ServerCalls

object ServerCalls(source)

Helpers for implementing a gRPC server based on a Kotlin coroutine implementation.

Functions

Link copied to clipboard
fun <RequestT, ResponseT> bidiStreamingServerMethodDefinition(context: CoroutineContext, descriptor: MethodDescriptor<RequestT, ResponseT>, implementation: (requests: Flow<RequestT>) -> Flow<ResponseT>): ServerMethodDefinition<RequestT, ResponseT>

Creates a ServerMethodDefinition that implements the specified bidirectional-streaming RPC method by running the specified implementation and associated implementation details within a per-RPC CoroutineScope generated with the specified CoroutineContext.

Link copied to clipboard
fun <RequestT, ResponseT> clientStreamingServerMethodDefinition(context: CoroutineContext, descriptor: MethodDescriptor<RequestT, ResponseT>, implementation: suspend (requests: Flow<RequestT>) -> ResponseT): ServerMethodDefinition<RequestT, ResponseT>

Creates a ServerMethodDefinition that implements the specified client-streaming RPC method by running the specified implementation and associated implementation details within a per-RPC CoroutineScope generated with the specified CoroutineContext.

Link copied to clipboard
fun <RequestT, ResponseT> serverStreamingServerMethodDefinition(context: CoroutineContext, descriptor: MethodDescriptor<RequestT, ResponseT>, implementation: (request: RequestT) -> Flow<ResponseT>): ServerMethodDefinition<RequestT, ResponseT>

Creates a ServerMethodDefinition that implements the specified server-streaming RPC method by running the specified implementation and associated implementation details within a per-RPC CoroutineScope generated with the specified CoroutineContext. When the RPC is received, this method definition will collect the flow returned by implementation and send the emitted values back to the client.

Link copied to clipboard
fun <RequestT, ResponseT> unaryServerMethodDefinition(context: CoroutineContext, descriptor: MethodDescriptor<RequestT, ResponseT>, implementation: suspend (request: RequestT) -> ResponseT): ServerMethodDefinition<RequestT, ResponseT>

Creates a ServerMethodDefinition that implements the specified unary RPC method by running the specified implementation and associated implementation details within a per-RPC CoroutineScope generated with the specified CoroutineContext.