Home
last modified time | relevance | path

Searched refs:CachingByteStream (Results 1 – 5 of 5) sorted by relevance

/external/grpc-grpc/src/core/lib/transport/
Dbyte_stream.cc101 ByteStreamCache::CachingByteStream::CachingByteStream(ByteStreamCache* cache) in CachingByteStream() function in grpc_core::ByteStreamCache::CachingByteStream
104 ByteStreamCache::CachingByteStream::~CachingByteStream() {} in ~CachingByteStream()
106 void ByteStreamCache::CachingByteStream::Orphan() { in Orphan()
114 bool ByteStreamCache::CachingByteStream::Next(size_t max_size_hint, in Next()
122 grpc_error* ByteStreamCache::CachingByteStream::Pull(grpc_slice* slice) { in Pull()
147 void ByteStreamCache::CachingByteStream::Shutdown(grpc_error* error) { in Shutdown()
155 void ByteStreamCache::CachingByteStream::Reset() { in Reset()
Dbyte_stream.h124 class CachingByteStream : public ByteStream {
126 explicit CachingByteStream(ByteStreamCache* cache);
128 ~CachingByteStream();
/external/grpc-grpc/test/core/transport/
Dbyte_stream_test.cc118 TEST(CachingByteStream, Basic) { in TEST() argument
134 ByteStreamCache::CachingByteStream stream(&cache); in TEST()
153 TEST(CachingByteStream, Reset) { in TEST() argument
169 ByteStreamCache::CachingByteStream stream(&cache); in TEST()
195 TEST(CachingByteStream, SharedCache) { in TEST() argument
211 ByteStreamCache::CachingByteStream stream1(&cache); in TEST()
212 ByteStreamCache::CachingByteStream stream2(&cache); in TEST()
/external/grpc-grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc65 grpc_core::ManualConstructor<grpc_core::ByteStreamCache::CachingByteStream>
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc856 grpc_core::ManualConstructor<grpc_core::ByteStreamCache::CachingByteStream>