Class CacheReadingPublisher

java.lang.Object

com.github.mizosoft.methanol.internal.cache.CacheReadingPublisher

All Implemented Interfaces:

Flow.Publisher<List<ByteBuffer>>

public final class CacheReadingPublisher
extends Object
implements Flow.Publisher<List<ByteBuffer>>

Publisher for the response body as read from a cached entry's Store.Viewer.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	CacheReadingPublisher.Listener

Constructor Summary

Constructors

Constructor	Description
CacheReadingPublisher(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 Type	Method	Description
void	subscribe(Flow.Subscriber<? super List<ByteBuffer>> subscriber)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CacheReadingPublisher

public CacheReadingPublisher(Store.Viewer viewer,
 Executor executor)

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

public void subscribe(Flow.Subscriber<? super List<ByteBuffer>> subscriber)

Specified by:

subscribe in interface Flow.Publisher<List<ByteBuffer>>