Home
last modified time | relevance | path

Searched defs:requestStream (Results 1 – 15 of 15) sorted by relevance

/aosp_15_r20/external/flatbuffers/tests/
H A Dmonster_test_grpc.d.ts16 requestStream: boolean; // false property
26 requestStream: boolean; // false property
36 requestStream: boolean; // true property
46 requestStream: boolean; // true property
/aosp_15_r20/external/aws-sdk-java-v2/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/
H A Dtest-json-async-client-interface.java285Publisher<InputEventStream> requestStream, EventStreamOperationResponseHandler asyncResponseHandle… in eventStreamOperation()
316 …amOperationRequest.Builder> eventStreamOperationRequest, Publisher<InputEventStream> requestStream, in eventStreamOperation()
344 Publisher<InputEventStreamTwo> requestStream) { in eventStreamOperationWithOnlyInput()
377 Publisher<InputEventStreamTwo> requestStream) { in eventStreamOperationWithOnlyInput()
H A Dtest-abstract-async-client-class.java169Publisher<InputEventStream> requestStream, EventStreamOperationResponseHandler asyncResponseHandle… in eventStreamOperation()
197 Publisher<InputEventStreamTwo> requestStream) { in eventStreamOperationWithOnlyInput()
H A Dtest-aws-json-async-client-class.java301Publisher<InputEventStream> requestStream, EventStreamOperationResponseHandler asyncResponseHandle… in eventStreamOperation()
395 Publisher<InputEventStreamTwo> requestStream) { in eventStreamOperationWithOnlyInput()
H A Dtest-json-async-client-class.java368Publisher<InputEventStream> requestStream, EventStreamOperationResponseHandler asyncResponseHandle… in eventStreamOperation()
465 Publisher<InputEventStreamTwo> requestStream) { in eventStreamOperationWithOnlyInput()
/aosp_15_r20/external/flatbuffers/grpc/examples/ts/greeter/src/
H A Dgreeter_grpc.d.ts14 requestStream: boolean; // false property
24 requestStream: boolean; // false property
/aosp_15_r20/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
H A DAbstractInteropTest.java929 StreamObserver<StreamingOutputCallRequest> requestStream = in fullDuplexCallShouldSucceed() local
967 StreamObserver<StreamingOutputCallRequest> requestStream = asyncStub.halfDuplexCall(recorder); in halfDuplexCallShouldSucceed() local
1118 StreamObserver<Messages.StreamingOutputCallRequest> requestStream = in exchangeMetadataStreamingCall() local
1548 StreamObserver<Messages.StreamingOutputCallRequest> requestStream = in customMetadata() local
/aosp_15_r20/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
H A DClientResponseObserver.java41 void beforeStart(final ClientCallStreamObserver<ReqT> requestStream); in beforeStart()
/aosp_15_r20/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
H A DClientCallsTest.java603 private ClientCallStreamObserver<Integer> requestStream; in canCaptureInboundFlowControlForServerStreamingObserver() field in ClientCallsTest.ResponseObserver
606 public void beforeStart(ClientCallStreamObserver<Integer> requestStream) { in canCaptureInboundFlowControlForServerStreamingObserver()
/aosp_15_r20/external/aws-sdk-java-v2/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/sra/
H A Dtest-aws-json-async-client-class.java294Publisher<InputEventStream> requestStream, EventStreamOperationResponseHandler asyncResponseHandle… in eventStreamOperation()
387 Publisher<InputEventStreamTwo> requestStream) { in eventStreamOperationWithOnlyInput()
H A Dtest-json-async-client-class.java359Publisher<InputEventStream> requestStream, EventStreamOperationResponseHandler asyncResponseHandle… in eventStreamOperation()
455 Publisher<InputEventStreamTwo> requestStream) { in eventStreamOperationWithOnlyInput()
/aosp_15_r20/external/aws-sdk-java-v2/test/protocol-tests/src/test/java/software/amazon/awssdk/protocol/tests/connection/
H A DSyncClientConnectionTest.java133 ClosableStringInputStream requestStream = new ClosableStringInputStream("{}"); in streamingIn_providedRequestBody_shouldNotCloseRequestStream() local
/aosp_15_r20/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
H A DHttp2OkHttpTest.java127 StreamObserver<Messages.StreamingOutputCallRequest> requestStream = in receivedDataForFinishedStream() local
/aosp_15_r20/external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/tracing/
H A DTracedClientStreamingCallableTest.java153 ApiStreamObserver<String> requestStream = in testRequestNotify() local
/aosp_15_r20/external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/
H A DProtoReflectionServiceTest.java629 public void beforeStart(final ClientCallStreamObserver<ServerReflectionRequest> requestStream) { in beforeStart()