Home
last modified time | relevance | path

Searched refs:AbstractClientStream (Results 1 – 6 of 6) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAbstractClientStreamTest.java43 import io.grpc.internal.AbstractClientStream.TransportState;
103 AbstractClientStream stream = in cancel_doNotAcceptOk()
122 AbstractClientStream stream = in cancel_failsOnNull()
133 AbstractClientStream stream = new BaseAbstractClientStream(allocator, state, new BaseSink() { in cancel_notifiesOnlyOnce()
150 AbstractClientStream stream = in startFailsOnNullListener()
160 AbstractClientStream stream = in cantCallStartTwice()
171 AbstractClientStream stream = in inboundDataReceived_failsOnNullFrame()
183 AbstractClientStream stream = in inboundHeadersReceived_notifiesListener()
194 AbstractClientStream stream = in inboundHeadersReceived_failsIfStatusReported()
207 AbstractClientStream stream = in inboundHeadersReceived_acceptsGzipContentEncoding()
[all …]
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyClientStream.java32 import io.grpc.internal.AbstractClientStream;
51 class NettyClientStream extends AbstractClientStream {
113 private class Sink implements AbstractClientStream.Sink {
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DAbstractClientStream.java47 public abstract class AbstractClientStream extends AbstractStream class
50 private static final Logger log = Logger.getLogger(AbstractClientStream.class.getName());
107 protected AbstractClientStream( in AbstractClientStream() method in AbstractClientStream
DHttp2ClientStreamTransportState.java31 public abstract class Http2ClientStreamTransportState extends AbstractClientStream.TransportState {
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpClientStream.java28 import io.grpc.internal.AbstractClientStream;
44 class OkHttpClientStream extends AbstractClientStream {
134 class Sink implements AbstractClientStream.Sink {
/external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
DCronetClientStream.java35 import io.grpc.internal.AbstractClientStream;
62 class CronetClientStream extends AbstractClientStream {
130 class Sink implements AbstractClientStream.Sink {