Home
last modified time | relevance | path

Searched refs:StreamObserver (Results 1 – 25 of 86) sorted by relevance

1234

/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DMoreInProcessTest.java29 import io.grpc.stub.StreamObserver;
82 public StreamObserver<StreamingInputCallRequest> streamingInputCall( in asyncClientStreaming_serverResponsePriorToRequest()
83 StreamObserver<StreamingInputCallResponse> responseObserver) { in asyncClientStreaming_serverResponsePriorToRequest()
87 return new StreamObserver<StreamingInputCallRequest>() { in asyncClientStreaming_serverResponsePriorToRequest()
108 StreamObserver<StreamingInputCallResponse> responseObserver = in asyncClientStreaming_serverResponsePriorToRequest()
109 new StreamObserver<StreamingInputCallResponse>() { in asyncClientStreaming_serverResponsePriorToRequest()
141 public StreamObserver<StreamingInputCallRequest> streamingInputCall( in asyncClientStreaming_serverErrorPriorToRequest()
142 StreamObserver<StreamingInputCallResponse> responseObserver) { in asyncClientStreaming_serverErrorPriorToRequest()
146 return new StreamObserver<StreamingInputCallRequest>() { in asyncClientStreaming_serverErrorPriorToRequest()
167 StreamObserver<StreamingInputCallResponse> responseObserver = in asyncClientStreaming_serverErrorPriorToRequest()
[all …]
/external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/routeguide/
DRouteGuideClientTest.java33 import io.grpc.stub.StreamObserver;
120 public void getFeature(Point point, StreamObserver<Feature> responseObserver) { in getFeature()
148 public void getFeature(Point point, StreamObserver<Feature> responseObserver) { in getFeature_error()
176 public void listFeatures(Rectangle rectangle, StreamObserver<Feature> responseObserver) { in listFeatures()
215 public void listFeatures(Rectangle rectangle, StreamObserver<Feature> responseObserver) { in listFeatures_error()
270 public StreamObserver<Point> recordRoute( in recordRoute()
271 final StreamObserver<RouteSummary> responseObserver) { in recordRoute()
272 StreamObserver<Point> requestObserver = new StreamObserver<Point>() { in recordRoute()
324 public StreamObserver<Point> recordRoute(StreamObserver<RouteSummary> responseObserver) { in recordRoute_serverError()
328 StreamObserver<Point> requestObserver = new StreamObserver<Point>() { in recordRoute_serverError()
[all …]
DRouteGuideServerTest.java31 import io.grpc.stub.StreamObserver;
138 StreamObserver<Feature> responseObserver = in listFeatures()
139 new StreamObserver<Feature>() { in listFeatures()
181 StreamObserver<RouteSummary> responseObserver = in recordRoute()
182 (StreamObserver<RouteSummary>) mock(StreamObserver.class); in recordRoute()
186 StreamObserver<Point> requestObserver = stub.recordRoute(responseObserver); in recordRoute()
219 StreamObserver<RouteNote> responseObserver = in routeChat()
220 (StreamObserver<RouteNote>) mock(StreamObserver.class); in routeChat()
223 StreamObserver<RouteNote> requestObserver = stub.routeChat(responseObserver); in routeChat()
/external/grpc-grpc-java/services/src/test/java/io/grpc/services/
DChannelzServiceTest.java39 import io.grpc.stub.StreamObserver;
149 StreamObserver<GetTopChannelsResponse> observer = mock(StreamObserver.class); in getTopChannelHelper()
162 StreamObserver<GetChannelResponse> observer = mock(StreamObserver.class); in getChannelHelper()
173 StreamObserver<GetChannelResponse> observer = mock(StreamObserver.class); in assertChannelNotFound()
183 StreamObserver<GetSubchannelResponse> observer = mock(StreamObserver.class); in getSubchannelHelper()
194 StreamObserver<GetSubchannelResponse> observer = mock(StreamObserver.class); in assertSubchannelNotFound()
204 StreamObserver<GetServersResponse> observer = mock(StreamObserver.class); in getServersHelper()
217 StreamObserver<GetSocketResponse> observer = mock(StreamObserver.class); in assertSocketNotFound()
227 StreamObserver<GetSocketResponse> observer = mock(StreamObserver.class); in getSocketHelper()
DHealthStatusManagerTest.java32 import io.grpc.stub.StreamObserver;
62 StreamObserver<HealthCheckResponse> observer = mock(StreamObserver.class); in checkValidStatus()
81 StreamObserver<HealthCheckResponse> observer = mock(StreamObserver.class); in checkStatusNotFound()
102 StreamObserver<HealthCheckResponse> observer = mock(StreamObserver.class); in notFoundForClearedStatus()
/external/flatbuffers/grpc/tests/
DJavaGrpcTest.java25 import io.grpc.stub.StreamObserver;
54 public void store(Monster request, io.grpc.stub.StreamObserver<Stat> responseObserver) { in store()
66 public void retrieve(Stat request, io.grpc.stub.StreamObserver<Monster> responseObserver) { in retrieve()
76 public StreamObserver<Monster> getMaxHitPoint(final StreamObserver<Stat> responseObserver) { in getMaxHitPoint()
81 … public StreamObserver<Monster> getMinMaxHitPoints(final StreamObserver<Stat> responseObserver) { in getMinMaxHitPoints()
85 …private StreamObserver<Monster> computeMinMax(final StreamObserver<Stat> responseObserver, final b… in computeMinMax()
94 return new StreamObserver<Monster>() { in computeMinMax()
179 StreamObserver<Stat> statObserver = new StreamObserver<Stat>() {
188 StreamObserver<Monster> monsterStream = asyncStub.getMaxHitPoint(statObserver);
208 StreamObserver<Stat> statObserver = new StreamObserver<Stat>() {
[all …]
/external/opencensus-java/exporters/trace/ocagent/src/test/java/io/opencensus/exporter/trace/ocagent/
DFakeOcAgentTraceServiceGrpcImpl.java23 import io.grpc.stub.StreamObserver;
59 private final AtomicReference<StreamObserver<UpdatedLibraryConfig>> updatedConfigObserverRef =
62 private final StreamObserver<CurrentLibraryConfig> currentConfigObserver =
63 new StreamObserver<CurrentLibraryConfig>() {
68 StreamObserver<UpdatedLibraryConfig> updatedConfigObserver =
84 private final StreamObserver<ExportTraceServiceRequest> exportRequestObserver =
85 new StreamObserver<ExportTraceServiceRequest>() {
101 public StreamObserver<CurrentLibraryConfig> config( in config()
102 StreamObserver<UpdatedLibraryConfig> updatedLibraryConfigStreamObserver) { in config()
108 public StreamObserver<ExportTraceServiceRequest> export( in export()
[all …]
DFakeOcAgentTraceServiceGrpcImplTest.java21 import io.grpc.stub.StreamObserver;
40 private final StreamObserver<UpdatedLibraryConfig> updatedConfigObserver =
41 new StreamObserver<UpdatedLibraryConfig>() {
55 private final StreamObserver<ExportTraceServiceResponse> exportResponseObserver =
56 new StreamObserver<ExportTraceServiceResponse>() {
78 StreamObserver<ExportTraceServiceRequest> exportRequestObserver = in export()
88 StreamObserver<CurrentLibraryConfig> currentConfigObsever = in config()
101 StreamObserver<CurrentLibraryConfig> currentConfigObsever = in config_WithNeverSampler()
/external/flatbuffers/tests/MyGame/Example/
DMonsterStorageGrpc.java227 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()
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()
[all …]
/external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/
DBenchmarkServiceGrpc.java224 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { in unaryCall()
235 … public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleRequest> streamingCall( in streamingCall()
236 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { in streamingCall()
246 …public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleRequest> streamingFromC… in streamingFromClient()
247 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { in streamingFromClient()
258 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { in streamingFromServer()
268 …public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleRequest> streamingBothW… in streamingBothWays()
269 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { in streamingBothWays()
339 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { in unaryCall()
351 … public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleRequest> streamingCall( in streamingCall()
[all …]
DWorkerServiceGrpc.java195 public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ServerArgs> runServer( in runServer()
196 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ServerStatus> responseObserver) { in runServer()
210 public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ClientArgs> runClient( in runClient()
211 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ClientStatus> responseObserver) { in runClient()
221 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.CoreResponse> responseObserver) { in coreCount()
231 io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.Void> responseObserver) { in quitWorker()
297 public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ServerArgs> runServer( in runServer()
298 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ServerStatus> responseObserver) { in runServer()
313 public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ClientArgs> runClient( in runClient()
314 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ClientStatus> responseObserver) { in runClient()
[all …]
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/
DAsyncServer.java29 import io.grpc.stub.StreamObserver;
214 StreamObserver<Messages.SimpleResponse> responseObserver) { in unaryCall()
220 public StreamObserver<Messages.SimpleRequest> streamingCall( in streamingCall()
221 final StreamObserver<Messages.SimpleResponse> observer) { in streamingCall()
225 return new StreamObserver<Messages.SimpleRequest>() { in streamingCall()
250 public StreamObserver<Messages.SimpleRequest> streamingFromClient(
251 final StreamObserver<Messages.SimpleResponse> responseObserver) {
252 return new StreamObserver<Messages.SimpleRequest>() {
287 final StreamObserver<Messages.SimpleResponse> observer) {
315 public StreamObserver<Messages.SimpleRequest> streamingBothWays(
[all …]
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
DTestServiceGrpc.java327 … io.grpc.stub.StreamObserver<io.grpc.testing.integration.EmptyProtos.Empty> responseObserver) { in emptyCall()
337 …io.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.SimpleResponse> responseObserver)… in unaryCall()
349 …io.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.SimpleResponse> responseObserver)… in cacheableUnaryCall()
360 …io.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.StreamingOutputCallResponse> resp… in streamingOutputCall()
370 …public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.StreamingInputCallRequest>… in streamingInputCall()
371 …io.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.StreamingInputCallResponse> respo… in streamingInputCall()
382 …public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.StreamingOutputCallRequest… in fullDuplexCall()
383 …io.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.StreamingOutputCallResponse> resp… in fullDuplexCall()
395 …public io.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.StreamingOutputCallRequest… in halfDuplexCall()
396 …io.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.StreamingOutputCallResponse> resp… in halfDuplexCall()
[all …]
/external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/
DProtoReflectionServiceTest.java49 import io.grpc.stub.StreamObserver;
183 StreamObserver<ServerReflectionRequest> requestObserver = in fileByFilename()
210 StreamObserver<ServerReflectionRequest> requestObserver = in fileByFilenameConsistentForMutableServices()
216 StreamObserver<ServerReflectionRequest> requestObserver2 = in fileByFilenameConsistentForMutableServices()
222 StreamObserver<ServerReflectionRequest> requestObserver3 = in fileByFilenameConsistentForMutableServices()
252 StreamObserver<ServerReflectionRequest> requestObserver = in fileContainingSymbol()
287 StreamObserver<ServerReflectionRequest> requestObserver = in fileContainingNestedSymbol()
313 StreamObserver<ServerReflectionRequest> requestObserver = in fileContainingSymbolForMutableServices()
319 StreamObserver<ServerReflectionRequest> requestObserver2 = in fileContainingSymbolForMutableServices()
325 StreamObserver<ServerReflectionRequest> requestObserver3 = in fileContainingSymbolForMutableServices()
[all …]
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DServerCallsTest.java95 public StreamObserver<Integer> invoke(StreamObserver<Integer> responseObserver) { in runtimeStreamObserverIsServerCallStreamObserver()
145 public StreamObserver<Integer> invoke(StreamObserver<Integer> responseObserver) { in cannotSetOnCancelHandlerAfterServiceInvocation()
173 public StreamObserver<Integer> invoke(StreamObserver<Integer> responseObserver) { in cannotSetOnReadyHandlerAfterServiceInvocation()
201 public StreamObserver<Integer> invoke(StreamObserver<Integer> responseObserver) { in cannotDisableAutoFlowControlAfterServiceInvocation()
223 public StreamObserver<Integer> invoke(StreamObserver<Integer> responseObserver) { in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
246 public void invoke(Integer req, StreamObserver<Integer> responseObserver) { in disablingInboundAutoFlowControlForUnaryHasNoEffect()
265 public void invoke(Integer req, StreamObserver<Integer> responseObserver) { in onReadyHandlerCalledForUnaryRequest()
301 public void invoke(Integer req, StreamObserver<Integer> responseObserver) { in clientSendsOne_errorMissingRequest_unary()
319 public void invoke(Integer req, StreamObserver<Integer> responseObserver) { in clientSendsOne_errorMissingRequest_serverStreaming()
338 public void invoke(Integer req, StreamObserver<Integer> responseObserver) { in clientSendsOne_errorTooManyRequests_unary()
[all …]
/external/grpc-grpc-java/benchmarks/src/test/java/io/grpc/benchmarks/driver/
DLoadWorkerTest.java28 import io.grpc.stub.StreamObserver;
89 StreamObserver<Control.ClientArgs> clientObserver = startClient(clientArgsBuilder.build()); in runUnaryBlockingClosedLoop()
118 StreamObserver<Control.ClientArgs> clientObserver = startClient(clientArgsBuilder.build()); in runUnaryAsyncClosedLoop()
147 StreamObserver<Control.ClientArgs> clientObserver = startClient(clientArgsBuilder.build()); in runPingPongAsyncClosedLoop()
176 StreamObserver<Control.ClientArgs> clientObserver = startClient(clientArgsBuilder.build()); in runGenericPingPongAsyncClosedLoop()
180 private void assertWorkOccurred(StreamObserver<Control.ClientArgs> clientObserver) in assertWorkOccurred()
205 private StreamObserver<Control.ClientArgs> startClient(Control.ClientArgs clientArgs)
208 StreamObserver<Control.ClientArgs> clientObserver = workerServiceStub.runClient(
209 new StreamObserver<Control.ClientStatus>() {
238 StreamObserver<Control.ServerArgs> serverObserver =
[all …]
/external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/
DAltsHandshakerStub.java24 import io.grpc.stub.StreamObserver;
31 private final StreamObserver<HandshakerResp> reader = new Reader();
32 private final StreamObserver<HandshakerReq> writer;
47 AltsHandshakerStub(StreamObserver<HandshakerReq> writer) { in AltsHandshakerStub()
52 StreamObserver<HandshakerResp> getReaderForTest() { in getReaderForTest()
82 private class Reader implements StreamObserver<HandshakerResp> {
/external/grpc-grpc-java/testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/
DSimpleServiceGrpc.java197 io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleResponse> responseObserver) { in unaryRpc()
206 public io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleRequest> clientStreamingRpc( in clientStreamingRpc()
207 io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleResponse> responseObserver) { in clientStreamingRpc()
217 io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleResponse> responseObserver) { in serverStreamingRpc()
226 public io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleRequest> bidiStreamingRpc( in bidiStreamingRpc()
227 io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleResponse> responseObserver) { in bidiStreamingRpc()
292 io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleResponse> responseObserver) { in unaryRpc()
302 public io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleRequest> clientStreamingRpc( in clientStreamingRpc()
303 io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleResponse> responseObserver) { in clientStreamingRpc()
314 io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleResponse> responseObserver) { in serverStreamingRpc()
[all …]
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DTestServiceImpl.java30 import io.grpc.stub.StreamObserver;
78 StreamObserver<EmptyProtos.Empty> responseObserver) { in emptyCall()
87 public void unaryCall(SimpleRequest req, StreamObserver<SimpleResponse> responseObserver) { in unaryCall()
136 StreamObserver<StreamingOutputCallResponse> responseObserver) { in streamingOutputCall()
146 public StreamObserver<Messages.StreamingInputCallRequest> streamingInputCall( in streamingInputCall()
147 final StreamObserver<Messages.StreamingInputCallResponse> responseObserver) { in streamingInputCall()
148 return new StreamObserver<StreamingInputCallRequest>() { in streamingInputCall()
175 public StreamObserver<Messages.StreamingOutputCallRequest> fullDuplexCall( in fullDuplexCall()
176 final StreamObserver<Messages.StreamingOutputCallResponse> responseObserver) { in fullDuplexCall()
178 return new StreamObserver<StreamingOutputCallRequest>() { in fullDuplexCall()
[all …]
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/
DLoadWorker.java28 import io.grpc.stub.StreamObserver;
126 public StreamObserver<ServerArgs> runServer( in runServer()
127 final StreamObserver<Control.ServerStatus> responseObserver) { in runServer()
128 return new StreamObserver<ServerArgs>() { in runServer()
186 public StreamObserver<ClientArgs> runClient(
187 final StreamObserver<Control.ClientStatus> responseObserver) {
188 return new StreamObserver<ClientArgs>() {
239 StreamObserver<Control.CoreResponse> responseObserver) {
249 StreamObserver<Control.Void> responseObserver) {
/external/grpc-grpc-java/services/src/main/java/io/grpc/services/
DChannelzService.java41 import io.grpc.stub.StreamObserver;
67 GetTopChannelsRequest request, StreamObserver<GetTopChannelsResponse> responseObserver) { in getTopChannels()
78 GetChannelRequest request, StreamObserver<GetChannelResponse> responseObserver) { in getChannel()
96 GetServersRequest request, StreamObserver<GetServersResponse> responseObserver) { in getServers()
106 GetSubchannelRequest request, StreamObserver<GetSubchannelResponse> responseObserver) { in getSubchannel()
124 GetSocketRequest request, StreamObserver<GetSocketResponse> responseObserver) { in getSocket()
141 GetServerSocketsRequest request, StreamObserver<GetServerSocketsResponse> responseObserver) { in getServerSockets()
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DServerCalls.java221 StreamObserver<ReqT> requestObserver = method.invoke(responseObserver); in startCall()
231 private final StreamObserver<ReqT> requestObserver;
238 StreamObserver<ReqT> requestObserver, in StreamingServerCallListener()
296 void invoke(ReqT request, StreamObserver<RespT> responseObserver); in invoke()
300 StreamObserver<ReqT> invoke(StreamObserver<RespT> responseObserver); in invoke()
403 MethodDescriptor<?, ?> methodDescriptor, StreamObserver<?> responseObserver) { in asyncUnimplementedUnaryCall()
418 public static <T> StreamObserver<T> asyncUnimplementedStreamingCall( in asyncUnimplementedStreamingCall()
419 MethodDescriptor<?, ?> methodDescriptor, StreamObserver<?> responseObserver) { in asyncUnimplementedStreamingCall()
430 static class NoopStreamObserver<V> implements StreamObserver<V> {
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/routeguide/
DRouteGuideServer.java30 import io.grpc.stub.StreamObserver;
129 public void getFeature(Point request, StreamObserver<Feature> responseObserver) { in getFeature()
141 public void listFeatures(Rectangle request, StreamObserver<Feature> responseObserver) { in listFeatures()
169 public StreamObserver<Point> recordRoute(final StreamObserver<RouteSummary> responseObserver) { in recordRoute()
170 return new StreamObserver<Point>() { in recordRoute()
215 public StreamObserver<RouteNote> routeChat(final StreamObserver<RouteNote> responseObserver) { in routeChat()
216 return new StreamObserver<RouteNote>() { in routeChat()
/external/grpc-grpc-java/compiler/src/test/golden/
DTestService.java.txt262 … io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
273 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObs…
283 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> stream…
284 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObse…
295 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> fullB…
296 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObs…
308 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> halfB…
309 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObs…
319 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> import…
320 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObse…
[all …]
/external/grpc-grpc-java/compiler/src/testLite/golden/
DTestService.java.txt256 … io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) {
267 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObs…
277 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> stream…
278 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObse…
289 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> fullB…
290 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObs…
302 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallRequest> halfB…
303 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObs…
313 …public io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallRequest> import…
314 …io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObse…
[all …]

1234