Module id.xfunction

Package id.xfunction.concurrent.flow

Class SameThreadSubmissionPublisher<T>

Object

SubmissionPublisher<T>

SameThreadSubmissionPublisher<T>

All Implemented Interfaces:

AutoCloseable, Flow.Publisher<T>

public class SameThreadSubmissionPublisher<T>
extends SubmissionPublisher<T>

SubmissionPublisher which submits all messages sequentially one by one to each subscriber. Queue size of each subscriber is equal to 1 so submitting new messages will block until subscriber`s Flow.Subscriber.onNext(Object) completes.

See Also:

• for Publisher with no queues

Constructor Summary

Constructors

Constructor	Description
SameThreadSubmissionPublisher()

Method Summary

Methods inherited from class SubmissionPublisher

close, closeExceptionally, consume, estimateMaximumLag, estimateMinimumDemand, getClosedException, getExecutor, getMaxBufferCapacity, getNumberOfSubscribers, getSubscribers, hasSubscribers, isClosed, isSubscribed, offer, offer, submit, subscribe

Methods inherited from class Object

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

Constructor Details

SameThreadSubmissionPublisher

public SameThreadSubmissionPublisher()