A B C G H I K R S U V

A

AbstractCoroutineServerImpl - Class in io.grpc.kotlin

Skeleton implementation of a coroutine-based gRPC server implementation. Intended to be subclassed by generated code.

AbstractCoroutineServerImpl(context) - Constructor for class io.grpc.kotlin.AbstractCoroutineServerImpl

Skeleton implementation of a coroutine-based gRPC server implementation. Intended to be subclassed by generated code.

AbstractCoroutineServerImpl() - Constructor for class io.grpc.kotlin.AbstractCoroutineServerImpl

Skeleton implementation of a coroutine-based gRPC server implementation. Intended to be subclassed by generated code.

AbstractCoroutineStub<S extends AbstractCoroutineStub<S>> - Class in io.grpc.kotlin

A skeleton implementation of a coroutine-based client stub, suitable for extension by generated client stubs.

AbstractCoroutineStub(channel, callOptions) - Constructor for class io.grpc.kotlin.AbstractCoroutineStub

A skeleton implementation of a coroutine-based client stub, suitable for extension by generated client stubs.

B

bidiStreamingRpc(channel, method, requests, callOptions, headers) - Method in class io.grpc.kotlin.ClientCalls

Returns a Flow which launches the specified bidirectional-streaming RPC, collecting the requests flow, sending them to the server, and emitting the responses.

bidiStreamingRpcFunction(channel, method, callOptions, headers) - Method in class io.grpc.kotlin.ClientCalls

Returns a function object representing a bidirectional streaming RPC.

bidiStreamingServerMethodDefinition(context, descriptor, implementation) - Method in class io.grpc.kotlin.ServerCalls

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.

C

ClientCalls - Class in io.grpc.kotlin

Helpers for gRPC clients implemented in Kotlin. Can be used directly, but intended to be used from generated Kotlin APIs.

clientStreamingRpc(channel, method, requests, callOptions, headers, p) - Method in class io.grpc.kotlin.ClientCalls

Launches a client-streaming RPC on the specified channel, suspending until the server returns the result. The caller is expected to provide a Flow of requests.

clientStreamingRpcFunction(channel, method, callOptions, headers) - Method in class io.grpc.kotlin.ClientCalls

Returns a function object representing a client streaming RPC.

clientStreamingServerMethodDefinition(context, descriptor, implementation) - Method in class io.grpc.kotlin.ServerCalls

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.

Companion - Static variable in class io.grpc.kotlin.CoroutineContextServerInterceptor

coroutineContext(call, headers) - Method in class io.grpc.kotlin.CoroutineContextServerInterceptor

Override this function to return a CoroutineContext in which to execute call and headers. The returned CoroutineContext will override any corresponding context elements in the server object.

CoroutineContextServerInterceptor - Class in io.grpc.kotlin

A ServerInterceptor subtype that can install elements in the CoroutineContext where server logic is executed. These elements are applied "after" the AbstractCoroutineServerImpl.context; that is, the interceptor overrides the server's context.

CoroutineContextServerInterceptor() - Constructor for class io.grpc.kotlin.CoroutineContextServerInterceptor

A ServerInterceptor subtype that can install elements in the CoroutineContext where server logic is executed. These elements are applied "after" the AbstractCoroutineServerImpl.context; that is, the interceptor overrides the server's context.

CoroutineContextServerInterceptor.Companion - Class in io.grpc.kotlin

current() - Method in class io.grpc.kotlin.GrpcContextElement.Key

G

getContext() - Method in class io.grpc.kotlin.AbstractCoroutineServerImpl

The context in which to run server coroutines.

getKey() - Method in class io.grpc.kotlin.GrpcContextElement

GrpcContextElement - Class in io.grpc.kotlin

A CoroutineContext that propagates an associated io.grpc.Context to coroutines run using that context, regardless of thread.

GrpcContextElement(grpcContext) - Constructor for class io.grpc.kotlin.GrpcContextElement

A CoroutineContext that propagates an associated io.grpc.Context to coroutines run using that context, regardless of thread.

GrpcContextElement.Key - Class in io.grpc.kotlin

H

HelpersKt - Class in io.grpc.kotlin

HelpersKt() - Constructor for class io.grpc.kotlin.HelpersKt

I

INSTANCE - Static variable in class io.grpc.kotlin.ClientCalls

Helpers for gRPC clients implemented in Kotlin. Can be used directly, but intended to be used from generated Kotlin APIs.

INSTANCE - Static variable in class io.grpc.kotlin.ServerCalls

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

interceptCall(call, headers, next) - Method in class io.grpc.kotlin.CoroutineContextServerInterceptor

io.grpc.kotlin - package io.grpc.kotlin

K

Key - Static variable in class io.grpc.kotlin.GrpcContextElement

R

restoreThreadContext(context, oldState) - Method in class io.grpc.kotlin.GrpcContextElement

S

ServerCalls - Class in io.grpc.kotlin

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

serverStreamingRpc(channel, method, request, callOptions, headers) - Method in class io.grpc.kotlin.ClientCalls

Returns a Flow which launches the specified server-streaming RPC and emits the responses.

serverStreamingRpcFunction(channel, method, callOptions, headers) - Method in class io.grpc.kotlin.ClientCalls

Returns a function object representing a server streaming RPC.

serverStreamingServerMethodDefinition(context, descriptor, implementation) - Method in class io.grpc.kotlin.ServerCalls

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.

StubFor - Annotation Type in io.grpc.kotlin

StubFor() - Constructor for annotation type io.grpc.kotlin.StubFor

U

unaryRpc(channel, method, request, callOptions, headers, p) - Method in class io.grpc.kotlin.ClientCalls

Launches a unary RPC on the specified channel, suspending until the result is received.

unaryRpcFunction(channel, method, callOptions, headers) - Method in class io.grpc.kotlin.ClientCalls

Returns a function object representing a unary RPC.

unaryServerMethodDefinition(context, descriptor, implementation) - Method in class io.grpc.kotlin.ServerCalls

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.

updateThreadContext(context) - Method in class io.grpc.kotlin.GrpcContextElement

V

value() - Method in annotation type io.grpc.kotlin.StubFor

A B C G H I K R S U V