Searched refs:abstractClientStreamSink (Results 1 – 6 of 6) sorted by relevance
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | AbstractClientStream.java | 159 abstractClientStreamSink().writeHeaders(headers, null); in start()
168 protected abstract Sink abstractClientStreamSink(); in abstractClientStreamSink() method in AbstractClientStream
177 abstractClientStreamSink().request(numMessages); in request()
184 abstractClientStreamSink().writeFrame(frame, endOfStream, flush, numMessages); in deliverFrame()
199 abstractClientStreamSink().cancel(reason); in cancel()
508 abstractClientStreamSink().writeHeaders(headers, payload); in close()
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientStreamTest.java | 166 clientStream.abstractClientStreamSink().writeFrame(buffers[i], false, i == 2 || i == 4, 1); in write()
191 clientStream.abstractClientStreamSink().writeFrame(null, true, true, 1); in write()
290 clientStream.abstractClientStreamSink().writeFrame(writableBuffer, false, true, 1); in streamSucceeded()
315 clientStream.abstractClientStreamSink().writeFrame(null, true, true, 1); in streamSucceeded()
351 clientStream.abstractClientStreamSink().writeFrame(null, true, true, 1); in streamSucceededWithGrpcError()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyClientStream.java | 95 protected Sink abstractClientStreamSink() { in abstractClientStreamSink() method in NettyClientStream
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientStream.java | 101 protected Sink abstractClientStreamSink() { in abstractClientStreamSink() method in OkHttpClientStream
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientStream.java | 121 protected Sink abstractClientStreamSink() { in abstractClientStreamSink() method in CronetClientStream
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AbstractClientStreamTest.java | 488 protected Sink abstractClientStreamSink() { in abstractClientStreamSink() method in AbstractClientStreamTest.BaseAbstractClientStream
|