java.lang.Object
com.github.mizosoft.methanol.internal.cache.CacheReadingPublisher
- All Implemented Interfaces:
Flow.Publisher<List<ByteBuffer>>
Publisher for the response body as read from a cached entry's
Store.Viewer
.-
Nested Class Summary
-
Constructor Summary
ConstructorDescriptionCacheReadingPublisher
(Store.Viewer viewer, Executor executor) CacheReadingPublisher
(Store.Viewer viewer, Executor executor, CacheReadingPublisher.Listener listener) CacheReadingPublisher
(Store.Viewer viewer, Executor executor, CacheReadingPublisher.Listener listener, int bufferSize) -
Method Summary
Modifier and TypeMethodDescriptionvoid
subscribe
(Flow.Subscriber<? super List<ByteBuffer>> subscriber)
-
Constructor Details
-
CacheReadingPublisher
-
CacheReadingPublisher
public CacheReadingPublisher(Store.Viewer viewer, Executor executor, CacheReadingPublisher.Listener listener) -
CacheReadingPublisher
public CacheReadingPublisher(Store.Viewer viewer, Executor executor, CacheReadingPublisher.Listener listener, int bufferSize)
-
-
Method Details
-
subscribe
- Specified by:
subscribe
in interfaceFlow.Publisher<List<ByteBuffer>>
-