| /external/grpc-grpc-java/core/src/testFixtures/java/io/grpc/internal/ |
| D | AbstractTransportTest.java | 443 ClientStream clientStream = client.newStream( in openStreamPreventsTermination() local
496 ClientStream clientStream = client.newStream( in shutdownNowKillsClientStream() local
535 ClientStream clientStream = client.newStream( in shutdownNowKillsServerStream() local
815 ClientStream clientStream = client.newStream( in basicStream() local
969 ClientStream clientStream = client.newStream( in authorityPropagation() local
1001 ClientStream clientStream = client.newStream( in zeroMessageStream() local
1041 ClientStream clientStream = client.newStream( in earlyServerClose_withServerHeaders() local
1078 ClientStream clientStream = client.newStream( in earlyServerClose_noServerHeaders() local
1121 ClientStream clientStream = client.newStream( in earlyServerClose_serverFailure() local
1154 final ClientStream clientStream = in earlyServerClose_serverFailure_withClientCancelOnListenerClosed() local
[all …]
|
| /external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/rpc/ |
| D | BidiStream.java | 74 private ClientStream<RequestT> clientStream; field in BidiStream
80 void setClientStream(ClientStream<RequestT> clientStream) { in setClientStream()
|
| D | BidiStreamingCallable.java | 134 ClientStream<RequestT> clientStream = splitCall(stream.observer(), context); in call() local
|
| /external/sdk-platform-java/gax-java/gax-grpc/src/main/java/com/google/api/gax/grpc/ |
| D | GrpcDirectBidiStreamingCallable.java | 63 final ClientStream<RequestT> clientStream = in internalCall() local
|
| /external/pigweed/pw_rpc/java/main/dev/pigweed/pw_rpc/ |
| D | Packets.java | 59 public static byte[] clientStream(PendingRpc rpc, MessageLite payload) { in clientStream() method in Packets
|
| D | Endpoint.java | 163 public synchronized boolean clientStream(AbstractCall<?, ?> call, MessageLite payload) in clientStream() method in Endpoint
|
| /external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/tracing/ |
| D | TracedBidiCallableTest.java | 191 FakeClientStream clientStream; field in TracedBidiCallableTest.FakeBidiCallable
245 private ClientStream<String> clientStream; field in TracedBidiCallableTest.FakeBidiObserver
|
| D | TracedClientStreamingCallableTest.java | 105 ApiStreamObserver<String> clientStream = in testOperationCancelled() local
|
| /external/sdk-platform-java/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/it/ |
| D | ITBidiStreaming.java | 59 ClientStream<EchoRequest> clientStream = grpcClient.chatCallable().splitCall(responseObserver); in testGrpc_splitCall_shouldListensToResponse() local
|
| /external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/tracing/ |
| D | TracedBidiCallable.java | 86 ClientStream<RequestT> clientStream = in internalCall() local
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientTransport.java | 132 final CronetClientStream clientStream = new CronetClientStream( in newStream() field in CronetClientTransport.StartCallback
|
| /external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/rpc/testing/ |
| D | FakeStreamingApi.java | 58 private AccumulatingClientStream<RequestT> clientStream; field in FakeStreamingApi.BidiStreamingStashCallable
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientStreamTest.java | 90 CronetClientStream clientStream; field in CronetClientStreamTest
|
| /external/conscrypt/repackaged/common/src/test/java/com/android/org/conscrypt/javax/net/ssl/ |
| D | SSLSocketTest.java | 1067 InputStream clientStream = pair.client.getInputStream(); in writeFromHandshakeListener() local
|
| /external/conscrypt/common/src/test/java/org/conscrypt/javax/net/ssl/ |
| D | SSLSocketTest.java | 1069 InputStream clientStream = pair.client.getInputStream(); in writeFromHandshakeListener() local
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientTransport.java | 415 void streamReadyToStart(OkHttpClientStream clientStream) { in streamReadyToStart()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyClientHandler.java | 886 private NettyClientStream.TransportState clientStream(Http2Stream stream) { in clientStream() method in NettyClientHandler
|