Searched refs:SERVER_STREAMING (Results 1 – 14 of 14) sorted by relevance
/third_party/grpc/include/grpcpp/impl/codegen/ |
D | server_interceptor.h | 59 enum class Type { UNARY, CLIENT_STREAMING, SERVER_STREAMING, BIDI_STREAMING }; enumerator 88 static_assert(Type::SERVER_STREAMING == 89 static_cast<Type>(internal::RpcMethod::SERVER_STREAMING),
|
D | client_interceptor.h | 74 SERVER_STREAMING, enumerator 107 static_assert(Type::SERVER_STREAMING == 108 static_cast<Type>(internal::RpcMethod::SERVER_STREAMING),
|
D | rpc_method.h | 34 SERVER_STREAMING, // response streaming enumerator
|
/third_party/grpc/test/cpp/interop/ |
D | stress_interop_client.h | 44 SERVER_STREAMING, enumerator 64 {SERVER_STREAMING, "server_streaming"},
|
D | stress_interop_client.cc | 140 case SERVER_STREAMING: { in RunTest()
|
/third_party/grpc/src/python/grpcio_tests/tests/interop/ |
D | _intraop_test_case.py | 33 methods.TestCase.SERVER_STREAMING.test_interoperability(self.stub, None)
|
D | methods.py | 426 SERVER_STREAMING = 'server_streaming' variable in TestCase 448 elif self is TestCase.SERVER_STREAMING:
|
/third_party/flatbuffers/tests/ |
D | monster_test.grpc.fb.cc | 33 …d_Retrieve_(MonsterStorage_method_names[1], ::grpc::internal::RpcMethod::SERVER_STREAMING, channel) in Stub() 94 ::grpc::internal::RpcMethod::SERVER_STREAMING, in Service()
|
/third_party/grpc/src/python/grpcio_tests/tests_aio/interop/ |
D | local_interop_test.py | 48 await methods.test_interoperability(methods.TestCase.SERVER_STREAMING,
|
D | methods.py | 399 SERVER_STREAMING = 'server_streaming' variable in TestCase 420 TestCase.SERVER_STREAMING: _server_streaming,
|
/third_party/grpc/src/cpp/server/ |
D | server_cc.cc | 346 grpc::internal::RpcMethod::SERVER_STREAMING), in SyncRequest() 553 grpc::internal::RpcMethod::SERVER_STREAMING), in CallbackRequest() 1022 case grpc::internal::RpcMethod::SERVER_STREAMING: in PayloadHandlingForMethod()
|
/third_party/grpc/src/cpp/server/health/ |
D | default_health_check_service.cc | 162 kHealthWatchMethodName, internal::RpcMethod::SERVER_STREAMING, nullptr)); in HealthCheckServiceImpl()
|
/third_party/flatbuffers/tests/MyGame/Example/ |
D | MonsterStorageGrpc.java | 115 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) in getRetrieveMethod()
|
/third_party/grpc/test/cpp/end2end/ |
D | server_interceptors_end2end_test.cc | 68 type == experimental::ServerRpcInfo::Type::SERVER_STREAMING) || in LoggingInterceptor()
|