Package io.quarkus.grpc.runtime.supports.context

Class GrpcDuplicatedContextGrpcInterceptor.ListenedOnDuplicatedContext<ReqT,RespT>

java.lang.Object

io.grpc.ServerCall.Listener<ReqT>

io.quarkus.grpc.runtime.supports.context.GrpcDuplicatedContextGrpcInterceptor.ListenedOnDuplicatedContext<ReqT,RespT>

Enclosing class:

GrpcDuplicatedContextGrpcInterceptor

static class GrpcDuplicatedContextGrpcInterceptor.ListenedOnDuplicatedContext<ReqT,RespT>
extends io.grpc.ServerCall.Listener<ReqT>

Constructor Summary

Constructors

Constructor	Description
ListenedOnDuplicatedContext(io.quarkus.grpc.ExceptionHandlerProvider ehp, io.grpc.ServerCall<ReqT,RespT> call, Function<Runnable,io.grpc.ServerCall.Listener<ReqT>> listenerCreator, io.vertx.core.Context context)

Method Summary

Modifier and Type	Method	Description
void	onCancel()
void	onComplete()
void	onHalfClose()
void	onMessage(ReqT message)
void	onReady()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ListenedOnDuplicatedContext

public ListenedOnDuplicatedContext(io.quarkus.grpc.ExceptionHandlerProvider ehp,
 io.grpc.ServerCall<ReqT,RespT> call,
 Function<Runnable,io.grpc.ServerCall.Listener<ReqT>> listenerCreator,
 io.vertx.core.Context context)

Method Details

onMessage

public void onMessage(ReqT message)

Overrides:

onMessage in class io.grpc.ServerCall.Listener<ReqT>

onReady

public void onReady()

Overrides:

onReady in class io.grpc.ServerCall.Listener<ReqT>

onHalfClose

public void onHalfClose()

Overrides:

onHalfClose in class io.grpc.ServerCall.Listener<ReqT>

onCancel

public void onCancel()

Overrides:

onCancel in class io.grpc.ServerCall.Listener<ReqT>

onComplete

public void onComplete()

Overrides:

onComplete in class io.grpc.ServerCall.Listener<ReqT>