Lines Matching refs:stub
11 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
15 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
16 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
17 import static io.grpc.stub.ClientCalls.futureUnaryCall;
18 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
19 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
20 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
21 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
22 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
23 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
227 io.grpc.stub.StreamObserver<MyGame.Example.Stat> responseObserver) { in store()
234 io.grpc.stub.StreamObserver<MyGame.Example.Monster> responseObserver) { in retrieve()
240 public io.grpc.stub.StreamObserver<MyGame.Example.Monster> getMaxHitPoint( in getMaxHitPoint()
241 io.grpc.stub.StreamObserver<MyGame.Example.Stat> responseObserver) { in getMaxHitPoint()
247 public io.grpc.stub.StreamObserver<MyGame.Example.Monster> getMinMaxHitPoints( in getMinMaxHitPoints()
248 io.grpc.stub.StreamObserver<MyGame.Example.Stat> responseObserver) { in getMinMaxHitPoints()
288 …public static final class MonsterStorageStub extends io.grpc.stub.AbstractStub<MonsterStorageStub>…
307 io.grpc.stub.StreamObserver<MyGame.Example.Stat> responseObserver) { in store()
315 io.grpc.stub.StreamObserver<MyGame.Example.Monster> responseObserver) { in retrieve()
322 public io.grpc.stub.StreamObserver<MyGame.Example.Monster> getMaxHitPoint( in getMaxHitPoint()
323 io.grpc.stub.StreamObserver<MyGame.Example.Stat> responseObserver) { in getMaxHitPoint()
330 public io.grpc.stub.StreamObserver<MyGame.Example.Monster> getMinMaxHitPoints( in getMinMaxHitPoints()
331 io.grpc.stub.StreamObserver<MyGame.Example.Stat> responseObserver) { in getMinMaxHitPoints()
339 …public static final class MonsterStorageBlockingStub extends io.grpc.stub.AbstractStub<MonsterStor…
373 …public static final class MonsterStorageFutureStub extends io.grpc.stub.AbstractStub<MonsterStorag…
404 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
405 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
406 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
407 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
418 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
422 (io.grpc.stub.StreamObserver<MyGame.Example.Stat>) responseObserver); in invoke()
426 (io.grpc.stub.StreamObserver<MyGame.Example.Monster>) responseObserver); in invoke()
435 public io.grpc.stub.StreamObserver<Req> invoke( in invoke()
436 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
439 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.getMaxHitPoint( in invoke()
440 (io.grpc.stub.StreamObserver<MyGame.Example.Stat>) responseObserver); in invoke()
442 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.getMinMaxHitPoints( in invoke()
443 (io.grpc.stub.StreamObserver<MyGame.Example.Stat>) responseObserver); in invoke()