io.vertx.grpc

Class BlockingServerInterceptor

java.lang.Object

io.vertx.grpc.BlockingServerInterceptor

All Implemented Interfaces:

io.grpc.ServerInterceptor

public class BlockingServerInterceptor
extends Object
implements io.grpc.ServerInterceptor

Wraps the ServerInterceptor and executes it on worker thread. All incoming events will be deferred until the interception is completed.

Author:

Pavel Kopachevskiy, Ruslan Sennov

Method Summary

Modifier and Type	Method and Description
<ReqT,RespT> io.grpc.ServerCall.Listener<ReqT>	interceptCall(io.grpc.ServerCall<ReqT,RespT> serverCall, io.grpc.Metadata metadata, io.grpc.ServerCallHandler<ReqT,RespT> serverCallHandler)
static io.grpc.ServerInterceptor	wrap(Vertx vertx, io.grpc.ServerInterceptor interceptor)

Methods inherited from class java.lang.Object

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

Method Detail

wrap

public static io.grpc.ServerInterceptor wrap(Vertx vertx,
                                             io.grpc.ServerInterceptor interceptor)

interceptCall

public <ReqT,RespT> io.grpc.ServerCall.Listener<ReqT> interceptCall(io.grpc.ServerCall<ReqT,RespT> serverCall,
                                                                    io.grpc.Metadata metadata,
                                                                    io.grpc.ServerCallHandler<ReqT,RespT> serverCallHandler)

Specified by:

interceptCall in interface io.grpc.ServerInterceptor