io.grpc.kotlin

Class CoroutineContextServerInterceptor

io.grpc.kotlin.CoroutineContextServerInterceptor

public class 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.

See Also:

CoroutineContext

Field Detail

Companion

public static io.grpc.kotlin.CoroutineContextServerInterceptor.Companion Companion

Constructor Detail

CoroutineContextServerInterceptor

public 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.

See Also:

CoroutineContext

Method Detail

coroutineContext

@NotNull
public kotlin.coroutines.CoroutineContext coroutineContext(@NotNull
                                                                    io.grpc.ServerCall<?,?> call,
                                                                    @NotNull
                                                                    io.grpc.Metadata headers)

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.

This function will be called each time a call is executed.

See Also:

CoroutineContext, call, headers, CoroutineContext, call

interceptCall

@NotNull
public <ReqT,RespT> io.grpc.ServerCall.Listener<ReqT> interceptCall(@NotNull
                                                                             io.grpc.ServerCall<ReqT,RespT> call,
                                                                             @NotNull
                                                                             io.grpc.Metadata headers,
                                                                             @NotNull
                                                                             io.grpc.ServerCallHandler<ReqT,RespT> next)