Lines Matching full:io
10 import static io.grpc.MethodDescriptor.generateFullMethodName;
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;
37 @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
39 public static final io.grpc.MethodDescriptor<MyGame.Example.Monster,
42 private static volatile io.grpc.MethodDescriptor<MyGame.Example.Monster,
73 @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
74 public static io.grpc.MethodDescriptor<MyGame.Example.Monster,
76 io.grpc.MethodDescriptor<MyGame.Example.Monster, MyGame.Example.Stat> getStoreMethod; in getStoreMethod()
81 io.grpc.MethodDescriptor.<MyGame.Example.Monster, MyGame.Example.Stat>newBuilder() in getStoreMethod()
82 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) in getStoreMethod()
98 @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
100 public static final io.grpc.MethodDescriptor<MyGame.Example.Stat,
103 private static volatile io.grpc.MethodDescriptor<MyGame.Example.Stat,
106 @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
107 public static io.grpc.MethodDescriptor<MyGame.Example.Stat,
109 io.grpc.MethodDescriptor<MyGame.Example.Stat, MyGame.Example.Monster> getRetrieveMethod; in getRetrieveMethod()
114 io.grpc.MethodDescriptor.<MyGame.Example.Stat, MyGame.Example.Monster>newBuilder() in getRetrieveMethod()
115 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) in getRetrieveMethod()
131 @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
133 public static final io.grpc.MethodDescriptor<MyGame.Example.Monster,
136 private static volatile io.grpc.MethodDescriptor<MyGame.Example.Monster,
139 @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
140 public static io.grpc.MethodDescriptor<MyGame.Example.Monster,
142 io.grpc.MethodDescriptor<MyGame.Example.Monster, MyGame.Example.Stat> getGetMaxHitPointMethod; in getGetMaxHitPointMethod()
147 io.grpc.MethodDescriptor.<MyGame.Example.Monster, MyGame.Example.Stat>newBuilder() in getGetMaxHitPointMethod()
148 .setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING) in getGetMaxHitPointMethod()
164 @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
166 public static final io.grpc.MethodDescriptor<MyGame.Example.Monster,
169 private static volatile io.grpc.MethodDescriptor<MyGame.Example.Monster,
172 @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
173 public static io.grpc.MethodDescriptor<MyGame.Example.Monster,
175 … io.grpc.MethodDescriptor<MyGame.Example.Monster, MyGame.Example.Stat> getGetMinMaxHitPointsMethod; in getGetMinMaxHitPointsMethod()
180 io.grpc.MethodDescriptor.<MyGame.Example.Monster, MyGame.Example.Stat>newBuilder() in getGetMinMaxHitPointsMethod()
181 .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) in getGetMinMaxHitPointsMethod()
200 public static MonsterStorageStub newStub(io.grpc.Channel channel) { in newStub()
208 io.grpc.Channel channel) { in newBlockingStub()
216 io.grpc.Channel channel) { in newFutureStub()
222 public static abstract class MonsterStorageImplBase implements io.grpc.BindableService {
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()
252 @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { in bindService()
253 return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) in bindService()
288 …public static final class MonsterStorageStub extends io.grpc.stub.AbstractStub<MonsterStorageStub>…
289 private MonsterStorageStub(io.grpc.Channel channel) { in MonsterStorageStub()
293 private MonsterStorageStub(io.grpc.Channel channel, in MonsterStorageStub()
294 io.grpc.CallOptions callOptions) { in MonsterStorageStub()
299 protected MonsterStorageStub build(io.grpc.Channel channel, in build()
300 io.grpc.CallOptions callOptions) { in build()
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…
340 private MonsterStorageBlockingStub(io.grpc.Channel channel) { in MonsterStorageBlockingStub()
344 private MonsterStorageBlockingStub(io.grpc.Channel channel, in MonsterStorageBlockingStub()
345 io.grpc.CallOptions callOptions) { in MonsterStorageBlockingStub()
350 protected MonsterStorageBlockingStub build(io.grpc.Channel channel, in build()
351 io.grpc.CallOptions callOptions) { in build()
373 …public static final class MonsterStorageFutureStub extends io.grpc.stub.AbstractStub<MonsterStorag…
374 private MonsterStorageFutureStub(io.grpc.Channel channel) { in MonsterStorageFutureStub()
378 private MonsterStorageFutureStub(io.grpc.Channel channel, in MonsterStorageFutureStub()
379 io.grpc.CallOptions callOptions) { in MonsterStorageFutureStub()
384 protected MonsterStorageFutureStub build(io.grpc.Channel channel, in build()
385 io.grpc.CallOptions callOptions) { in build()
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()
450 private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
452 public static io.grpc.ServiceDescriptor getServiceDescriptor() { in getServiceDescriptor()
453 io.grpc.ServiceDescriptor result = serviceDescriptor; in getServiceDescriptor()
458 … serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) in getServiceDescriptor()