| /aosp_15_r20/external/grpc-grpc/examples/python/data_transmission/ |
| H A D | demo_pb2_grpc.py | 30 self.ServerStreamingMethod = channel.unary_stream(
66 def ServerStreamingMethod(self, request, context): member in GRPCDemoServicer
98 servicer.ServerStreamingMethod,
155 def ServerStreamingMethod(request, member in GRPCDemo
|
| H A D | README.cn.md | 27 `server.py: ServerStreamingMethod`
|
| H A D | client.py | 86 response_iterator = stub.ServerStreamingMethod(request)
|
| H A D | server.py | 63 def ServerStreamingMethod(self, request, context): member in DemoServer
|
| H A D | README.en.md | 27 `server.py: ServerStreamingMethod`
|
| H A D | demo.proto | 62 rpc ServerStreamingMethod (Request) returns (stream Response); rpc
|
| /aosp_15_r20/external/pigweed/pw_rpc/ |
| H A D | server_test.cc | 744 class ServerStreamingMethod : public BasicServer { class
746 ServerStreamingMethod() { in ServerStreamingMethod() function in pw::rpc::__anonaf12ed3f0111::ServerStreamingMethod
762 TEST_F(ServerStreamingMethod, ClientStream_InvalidArgumentError) { in TEST_F() argument
773 TEST_F(ServerStreamingMethod, ClientRequestedCompletion_CallsCallback) { in TEST_F() argument
787 TEST_F(ServerStreamingMethod, in TEST_F() argument
801 TEST_F(ServerStreamingMethod, ClientRequestedCompletion_ErrorWhenClosed) { in TEST_F() argument
809 TEST_F(ServerStreamingMethod, in TEST_F() argument
|
| /aosp_15_r20/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
| H A D | ServerCallsTest.java | 229 new ServerCalls.ServerStreamingMethod<Integer, Integer>() { in onCloseHandlerCalledIfSetInUnaryClientCall()
423 new ServerCalls.ServerStreamingMethod<Integer, Integer>() { in onReadyHandlerCalledForUnaryRequest()
477 new ServerCalls.ServerStreamingMethod<Integer, Integer>() { in clientSendsOne_errorMissingRequest_serverStreaming()
517 new ServerCalls.ServerStreamingMethod<Integer, Integer>() { in clientSendsOne_errorTooManyRequests_serverStreaming()
|
| H A D | ClientCallsTest.java | 52 import io.grpc.stub.ServerCalls.ServerStreamingMethod;
851 class NoopServerStreamingMethod implements ServerStreamingMethod<Integer, Integer> { in blockingServerStreamingCall_interruptedWaitsForOnClose()
890 class BasicServerStreamingResponse implements ServerStreamingMethod<Integer, Integer> { in blockingServerStreamingCall2_success()
921 class NoopServerStreamingMethod implements ServerStreamingMethod<Integer, Integer> { in blockingServerStreamingCall2_interruptedWaitsForOnClose()
|
| /aosp_15_r20/external/pigweed/pw_rpc/public/pw_rpc/internal/ |
| H A D | method_impl_tester.h | 172 ServerStreamingMethod(args).id() == 5 && in Pass()
204 constexpr MethodImpl ServerStreamingMethod( in ServerStreamingMethod() function
|
| /aosp_15_r20/external/sdk-platform-java/gax-java/gax-grpc/src/test/java/com/google/api/gax/grpc/testing/ |
| H A D | FakeServiceGrpc.java | 53 import io.grpc.stub.ServerCalls.ServerStreamingMethod;
185 ServerStreamingMethod<Req, Resp>,
|
| /aosp_15_r20/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| H A D | ServerCalls.java | 60 ServerStreamingMethod<ReqT, RespT> method) { in asyncServerStreamingCall()
94 public interface ServerStreamingMethod<ReqT, RespT> extends UnaryRequestMethod<ReqT, RespT> { interface in ServerCalls
|
| /aosp_15_r20/external/google-cloud-java/java-texttospeech/grpc-google-cloud-texttospeech-v1beta1/src/main/java/com/google/cloud/texttospeech/v1beta1/ |
| H A D | TextToSpeechLongAudioSynthesizeGrpc.java | 285 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
|
| /aosp_15_r20/external/google-cloud-java/java-phishingprotection/grpc-google-cloud-phishingprotection-v1beta1/src/main/java/com/google/phishingprotection/v1beta1/ |
| H A D | PhishingProtectionServiceV1Beta1Grpc.java | 310 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
|
| /aosp_15_r20/external/google-cloud-java/java-monitoring/grpc-google-cloud-monitoring-v3/src/main/java/com/google/monitoring/v3/ |
| H A D | QueryServiceGrpc.java | 285 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
|
| /aosp_15_r20/external/grpc-grpc-java/android-interop-testing/src/generated/debug/grpc/io/grpc/testing/integration/ |
| H A D | XdsUpdateClientConfigureServiceGrpc.java | 223 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
|
| /aosp_15_r20/external/google-cloud-java/java-video-intelligence/grpc-google-cloud-video-intelligence-v1p3beta1/src/main/java/com/google/cloud/videointelligence/v1p3beta1/ |
| H A D | StreamingVideoIntelligenceServiceGrpc.java | 272 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
|
| /aosp_15_r20/external/grpc-grpc-java/android-interop-testing/src/generated/release/grpc/io/grpc/testing/integration/ |
| H A D | UnimplementedServiceGrpc.java | 229 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
|
| /aosp_15_r20/external/grpc-grpc-java/xds/src/generated/thirdparty/grpc/io/envoyproxy/envoy/api/v2/ |
| H A D | VirtualHostDiscoveryServiceGrpc.java | 251 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
|
| /aosp_15_r20/external/google-cloud-java/java-mediatranslation/grpc-google-cloud-mediatranslation-v1beta1/src/main/java/com/google/cloud/mediatranslation/v1beta1/ |
| H A D | SpeechTranslationServiceGrpc.java | 265 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
|
| /aosp_15_r20/external/grpc-grpc-java/xds/src/generated/thirdparty/grpc/io/envoyproxy/envoy/service/load_stats/v2/ |
| H A D | LoadReportingServiceGrpc.java | 237 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
|
| /aosp_15_r20/external/google-cloud-java/java-dataflow/grpc-google-cloud-dataflow-v1beta3/src/main/java/com/google/dataflow/v1beta3/ |
| H A D | FlexTemplatesServiceGrpc.java | 279 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
|
| /aosp_15_r20/external/google-cloud-java/java-video-intelligence/grpc-google-cloud-video-intelligence-v1p2beta1/src/main/java/com/google/cloud/videointelligence/v1p2beta1/ |
| H A D | VideoIntelligenceServiceGrpc.java | 288 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
|
| /aosp_15_r20/external/grpc-grpc-java/rls/src/generated/main/grpc/io/grpc/lookup/v1/ |
| H A D | RouteLookupServiceGrpc.java | 206 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
|
| /aosp_15_r20/external/google-cloud-java/java-texttospeech/grpc-google-cloud-texttospeech-v1/src/main/java/com/google/cloud/texttospeech/v1/ |
| H A D | TextToSpeechLongAudioSynthesizeGrpc.java | 284 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
|