Searched refs:finishStream (Results 1 – 8 of 8) sorted by relevance
| /external/lzma/CPP/7zip/Compress/ |
| D | XzDecoder.cpp | 35 const UInt64 *outSizeLimit, bool finishStream, ICompressProgressInfo *progress) in Decode() argument
81 outSizeLimit, finishStream, in Decode()
102 if (res == SZ_OK && finishStream) in Decode()
|
| D | XzDecoder.h | 44 const UInt64 *outSizeLimit, bool finishStream, ICompressProgressInfo *compressProgress);
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientStream.java | 206 transport.finishStream(CronetClientStream.this, reason); in cancel()
360 private void finishStream(Status status) { in finishStream() method in CronetClientStream
361 transport.finishStream(this, status); in finishStream()
475 finishStream(toGrpcStatus(info)); in onSucceeded()
484 finishStream(Status.UNAVAILABLE.withCause(error)); in onFailed()
502 finishStream(status); in onCanceled()
|
| D | CronetClientTransport.java | 251 void finishStream(CronetClientStream stream, Status status) {
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientStream.java | 316 transport.finishStream( in transportDataReceived()
331 transport.finishStream(id(),null, PROCESSED, false, ErrorCode.CANCEL, null); in onEndOfStream()
333 transport.finishStream(id(), null, PROCESSED, false, null, null); in onEndOfStream()
356 transport.finishStream( in cancel()
|
| D | OkHttpClientTransport.java | 796 void finishStream( in finishStream() method in OkHttpClientTransport
1066 finishStream( in rstStream()
1170 finishStream( in windowUpdate()
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientStreamTest.java | 391 verify(transport).finishStream(eq(clientStream), isA(Status.class)); in streamFailed()
419 verify(transport).finishStream(eq(clientStream), isA(Status.class)); in streamFailedAfterResponseHeaderReceived()
450 verify(transport).finishStream(eq(clientStream), isA(Status.class)); in streamFailedAfterTrailerReceived()
483 verify(transport).finishStream(eq(clientStream), isA(Status.class)); in streamFailedAfterTrailerAndEndOfStreamReceived()
506 verify(transport, times(0)).finishStream(eq(clientStream), isA(Status.class)); in cancelStream()
510 verify(transport, times(1)).finishStream(eq(clientStream), statusCaptor.capture()); in cancelStream()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientStreamTest.java | 128 }).when(transport).finishStream( in cancel_started()
133 verify(transport).finishStream(1234, Status.CANCELLED, PROCESSED,true, ErrorCode.CANCEL, null); in cancel_started()
|