Module id.xfunction

Package id.xfunction.concurrent.flow

package id.xfunction.concurrent.flow

Related Packages

Package	Description
id.xfunction.concurrent

Class	Description
CollectorSubscriber<T,C extends Collection<T>>	Subscriber which collects items to target collection.
DelegateSubscriber<T>	Subscriber which wraps original subscriber and delegates all calls to it.
FixedCollectorSubscriber<T,C extends Collection<T>>	Subscriber which collects fixed number of items to target collection.
MergeProcessor<T>	Merge multiple subscriptions for different publishers into one.
ReplayablePublisher<T>	Publisher which caches last N submitted items and replays them to new subscribers.
ReplayableSubscriber<T>
SameThreadSubmissionPublisher<T>	SubmissionPublisher which submits all messages sequentially one by one to each subscriber.
SimpleSubscriber<T>	Simple implementation for Flow.Subscriber interface which can be subscribed only once.
SynchronousPublisher<T>	Publisher which has no internal queues and which delivers items to subscribers synchronously.
TransformProcessor<T,R>	Flow.Processor which can be used to transform publisher messages into different type.
TransformPublisher<T,R>	Transformer Flow.Publisher allows to subscribe existing Flow.Subscriber of type R to a Flow.Publisher of type T.
TransformSubscriber<T,R>	Transformer Flow.Subscriber allows to subscribe existing Flow.Subscriber of type R to a Flow.Publisher of type T.