Home
last modified time | relevance | path

Searched refs:realStream (Results 1 – 12 of 12) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DDelayedStreamTest.java60 @Mock private ClientStream realStream; field in DelayedStreamTest
74 stream.setStream(realStream); in setStream_setAuthority()
75 InOrder inOrder = inOrder(realStream); in setStream_setAuthority()
76 inOrder.verify(realStream).setAuthority(authority); in setStream_setAuthority()
77 inOrder.verify(realStream).start(any(ClientStreamListener.class)); in setStream_setAuthority()
104 stream.setStream(realStream); in setStream_sendsAllMessages()
106 verify(realStream).setCompressor(Codec.Identity.NONE); in setStream_sendsAllMessages()
107 verify(realStream).setDecompressorRegistry(DecompressorRegistry.getDefaultInstance()); in setStream_sendsAllMessages()
109 verify(realStream).setMessageCompression(true); in setStream_sendsAllMessages()
110 verify(realStream).setMessageCompression(false); in setStream_sendsAllMessages()
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DDelayedStream.java51 private ClientStream realStream; field in DelayedStream
62 realStream.setMaxInboundMessageSize(maxSize); in setMaxInboundMessageSize()
67 realStream.setMaxInboundMessageSize(maxSize); in setMaxInboundMessageSize()
76 realStream.setMaxOutboundMessageSize(maxSize); in setMaxOutboundMessageSize()
81 realStream.setMaxOutboundMessageSize(maxSize); in setMaxOutboundMessageSize()
92 realStream.setDeadline(deadline); in setDeadline()
106 if (realStream != null) { in setStream()
109 realStream = checkNotNull(stream, "stream"); in setStream()
121 assert realStream != null; in drainPendingCalls()
176 realStream.setAuthority(authority); in setAuthority()
[all …]
DMetadataApplierImpl.java67 ClientStream realStream; in apply() local
70 realStream = transport.newStream(method, origHeaders, callOptions); in apply()
74 finalizeWith(realStream); in apply()
DDelayedClientTransport.java355 ClientStream realStream; in createRealStream() local
358 realStream = transport.newStream( in createRealStream()
363 setStream(realStream); in createRealStream()
/external/lzma/C/
D7zStream.c87 res = ISeekInStream_Read(p->realStream, p->buf, &size2); in LookToRead2_Look_Lookahead()
107 res = ISeekInStream_Read(p->realStream, p->buf, size); in LookToRead2_Look_Exact()
128 return ISeekInStream_Read(p->realStream, buf, size); in LookToRead2_Read()
141 return ISeekInStream_Seek(p->realStream, pos, origin); in LookToRead2_Seek()
159 return LookInStream_LookRead(p->realStream, buf, size); in SecToLook_Read()
170 return ILookInStream_Read(p->realStream, buf, size); in SecToRead_Read()
DXzEnc.c233 ISeqInStream *realStream; member
268 if (p->realStream) in SeqCheckInStream_Read()
270 res = ISeqInStream_Read(p->realStream, data, &size2); in SeqCheckInStream_Read()
288 ISeqOutStream *realStream; member
297 if (p->realStream) in SeqSizeOutStream_Write()
298 size = ISeqOutStream_Write(p->realStream, data, size); in SeqSizeOutStream_Write()
317 ISeqInStream *realStream; member
359 RINOK(ISeqInStream_Read(p->realStream, p->buf, &p->endPos)); in SeqInFilter_Read()
767 seqSizeOutStream.realStream = outStream; in Xz_CompressBlock()
791 checkInStream.realStream = inStream; in Xz_CompressBlock()
[all …]
D7zTypes.h244 const ISeekInStream *realStream; member
262 const ILookInStream *realStream; member
272 const ILookInStream *realStream; member
DLzma2Enc.c43 ISeqInStream *realStream; member
70 res = ISeqInStream_Read(p->realStream, data, &size2); in LimitedSeqInStream_Read()
526 limitedInStream.realStream = inStream; in Lzma2Enc_EncodeMt1()
DXzIn.c231 secToRead.realStream = stream; in Xz_ReadBackward()
/external/lzma/C/Util/SfxSetup/
DSfxSetup.c388 lookStream.realStream = &archiveStream.vt; in main()
/external/lzma/C/Util/7z/
D7zMain.c439 lookStream.realStream = &archiveStream.vt; in main()
/external/lzma/CPP/7zip/Archive/
DXzHandler.cpp526 lookStream.realStream = &inStreamImp.vt; in Open2()