Module methanol

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

Class CacheWritingPublisher

java.lang.Object

com.github.mizosoft.methanol.internal.cache.CacheWritingPublisher

All Implemented Interfaces:

Flow.Publisher<List<ByteBuffer>>

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

A Publisher that writes the body stream into cache while simultaneously forwarding it to downstream. The publisher prefers writing the whole stream if downstream cancels the subscription midway transmission. Forwarding downstream items is advanced independently of writing them. Consequently, writing may lag behind downstream consumption, and may proceed after downstream has been completed. This affords the downstream not having to unnecessarily wait for the entire body to be cached. If an error occurs while writing, the edit is silently discarded.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	CacheWritingPublisher.Listener

Constructor Summary

Constructors

Constructor	Description
CacheWritingPublisher(Flow.Publisher<List<ByteBuffer>> upstream, Store.Editor editor, ByteBuffer metadata, Executor executor)
CacheWritingPublisher(Flow.Publisher<List<ByteBuffer>> upstream, Store.Editor editor, ByteBuffer metadata, Executor executor, CacheWritingPublisher.Listener listener)
CacheWritingPublisher(Flow.Publisher<List<ByteBuffer>> upstream, Store.Editor editor, ByteBuffer metadata, Executor executor, CacheWritingPublisher.Listener listener, boolean propagateCancellation)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

CacheWritingPublisher

public CacheWritingPublisher(Flow.Publisher<List<ByteBuffer>> upstream,
 Store.Editor editor,
 ByteBuffer metadata,
 Executor executor)

CacheWritingPublisher

public CacheWritingPublisher(Flow.Publisher<List<ByteBuffer>> upstream,
 Store.Editor editor,
 ByteBuffer metadata,
 Executor executor,
 CacheWritingPublisher.Listener listener)

CacheWritingPublisher

public CacheWritingPublisher(Flow.Publisher<List<ByteBuffer>> upstream,
 Store.Editor editor,
 ByteBuffer metadata,
 Executor executor,
 CacheWritingPublisher.Listener listener,
 boolean propagateCancellation)

Method Details

subscribe

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

Specified by:

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