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
187 abstractClientStreamSink().writeFrame(frame, endOfStream, flush, numMessages); in deliverFrame()
202 abstractClientStreamSink().cancel(reason); in cancel()
515 abstractClientStreamSink().writeHeaders(headers, payload); in close()
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientStreamTest.java | 179 clientStream.abstractClientStreamSink().writeFrame(buffers[i], false, i == 2 || i == 4, 1); in write()
204 clientStream.abstractClientStreamSink().writeFrame(null, true, true, 1); in write()
303 clientStream.abstractClientStreamSink().writeFrame(writableBuffer, false, true, 1); in streamSucceeded()
328 clientStream.abstractClientStreamSink().writeFrame(null, true, true, 1); in streamSucceeded()
364 clientStream.abstractClientStreamSink().writeFrame(null, true, true, 1); in streamSucceededWithGrpcError()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyClientStream.java | 103 protected Sink abstractClientStreamSink() { in abstractClientStreamSink() method in NettyClientStream
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientStream.java | 111 protected Sink abstractClientStreamSink() { in abstractClientStreamSink() method in OkHttpClientStream
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientStream.java | 140 protected Sink abstractClientStreamSink() { in abstractClientStreamSink() method in CronetClientStream
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AbstractClientStreamTest.java | 526 protected Sink abstractClientStreamSink() { in abstractClientStreamSink() method in AbstractClientStreamTest.BaseAbstractClientStream
|