Module methanol

Package com.github.mizosoft.methanol.internal.cache

Class CacheReadingPublisher

java.lang.Object

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

All Implemented Interfaces:

java.util.concurrent.Flow.Publisher<java.util.List<java.nio.ByteBuffer>>

public final class CacheReadingPublisher
extends java.lang.Object
implements java.util.concurrent.Flow.Publisher<java.util.List<java.nio.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, java.util.concurrent.Executor executor)
CacheReadingPublisher(Store.Viewer viewer, java.util.concurrent.Executor executor, CacheReadingPublisher.Listener listener)
CacheReadingPublisher(Store.Viewer viewer, java.util.concurrent.Executor executor, CacheReadingPublisher.Listener listener, int bufferSize)

Method Summary

Modifier and Type	Method	Description
void	subscribe(java.util.concurrent.Flow.Subscriber<? super java.util.List<java.nio.ByteBuffer>> subscriber)

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheReadingPublisher

public CacheReadingPublisher(Store.Viewer viewer,
                             java.util.concurrent.Executor executor)

CacheReadingPublisher

public CacheReadingPublisher(Store.Viewer viewer,
                             java.util.concurrent.Executor executor,
                             CacheReadingPublisher.Listener listener)

CacheReadingPublisher

public CacheReadingPublisher(Store.Viewer viewer,
                             java.util.concurrent.Executor executor,
                             CacheReadingPublisher.Listener listener,
                             int bufferSize)

Method Detail

subscribe

public void subscribe(java.util.concurrent.Flow.Subscriber<? super java.util.List<java.nio.ByteBuffer>> subscriber)

Specified by:

subscribe in interface java.util.concurrent.Flow.Publisher<java.util.List<java.nio.ByteBuffer>>