Searched refs:CronetClientStream (Results 1 – 5 of 5) sorted by relevance
56 private final Set<CronetClientStream> streams =57 new HashSet<CronetClientStream>();111 public CronetClientStream newStream(final MethodDescriptor<?, ?> method, final Metadata headers, in newStream()122 final CronetClientStream clientStream = new CronetClientStream( in newStream()144 private void startStream(CronetClientStream stream) { in startStream()187 ArrayList<CronetClientStream> streamsCopy;252 void finishStream(CronetClientStream stream, Status status) {
62 class CronetClientStream extends AbstractClientStream { class83 CronetClientStream( in CronetClientStream() method in CronetClientStream206 transport.finishStream(CronetClientStream.this, reason); in cancel()
78 CronetClientStream clientStream;86 private CronetClientStream stream;92 void setStream(CronetClientStream stream) { in setStream()109 new CronetClientStream( in setUp()320 ((CronetClientStream.BidirectionalStreamCallback) callback).processTrailers(trailers(0)); in streamSucceeded()365 ((CronetClientStream.BidirectionalStreamCallback) callback) in streamSucceededWithGrpcError()446 ((CronetClientStream.BidirectionalStreamCallback) callback).processTrailers(trailers(0)); in streamFailedAfterTrailerReceived()479 ((CronetClientStream.BidirectionalStreamCallback) callback).processTrailers(trailers(0)); in streamFailedAfterTrailerAndEndOfStreamReceived()530 ((CronetClientStream.BidirectionalStreamCallback) callback) in reportTrailersWhenTrailersReceivedBeforeReadClosed()564 ((CronetClientStream.BidirectionalStreamCallback) callback) in reportTrailersWhenTrailersReceivedAfterReadClosed()[all …]
65 CronetClientStream stream = transport.newStream(method, new Metadata(), CallOptions.DEFAULT); in alwaysUsePutTrue_cronetStreamIsIdempotent()79 CronetClientStream stream = transport.newStream(method, new Metadata(), CallOptions.DEFAULT); in alwaysUsePut_defaultsToFalse()
92 CronetClientStream stream1 = in shutdownTransport()94 CronetClientStream stream2 = in shutdownTransport()