Module id.xfunction

Package id.xfunction.concurrent.flow

Class FixedCollectorSubscriber<T,C extends Collection<T>>

Object

SimpleSubscriber<T>

FixedCollectorSubscriber<T,C>

All Implemented Interfaces:

ReplayableSubscriber<T>, Flow.Subscriber<T>

public class FixedCollectorSubscriber<T,C extends Collection<T>>
extends SimpleSubscriber<T>

Subscriber which collects fixed number of items to target collection.

When target collection size reaches maxSize:

• subscription is canceled
• future which is maintained by this subscriber completes

Example:

 // subscriber collects 5 items to ArrayList and then cancels subscription
 var subscriber = new FixedCollectorSubscriber<>(new ArrayList<String>(), 5);
 publisher.subscribe(subscriber);
 // wait for 5 items and print them to console
 System.out.println(subscriber.getFuture().get().toString());
 

Field Summary

Fields inherited from class SimpleSubscriber

subscription

Constructor Summary

Constructors

Constructor	Description
FixedCollectorSubscriber(C targetCollection, int maxSize)
FixedCollectorSubscriber(C targetCollection, int maxSize, Duration timeout)

Method Summary

Modifier and Type	Method	Description
Future<C>	getFuture()
void	onNext(T item)	Empty
void	onSubscribe(Flow.Subscription subscription)	Saves subscription and requests SimpleSubscriber.withInitialRequest(int) number of items.
void	replay(T item)	Empty
FixedCollectorSubscriber<T,C>	withMessageConsumer(Consumer<T> consumer)	Setup additional message consumer.

Methods inherited from class SimpleSubscriber

getSubscription, isSubscribed, onComplete, onError, withInitialRequest

Methods inherited from class Object

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

Constructor Details

FixedCollectorSubscriber

public FixedCollectorSubscriber(C targetCollection,
 int maxSize)

FixedCollectorSubscriber

public FixedCollectorSubscriber(C targetCollection,
 int maxSize,
 Duration timeout)

Parameters:

timeout - complete the future by timeout with whatever number of items received into targetCollection (may be less than maxSize)

Method Details

withMessageConsumer

public FixedCollectorSubscriber<T,C> withMessageConsumer(Consumer<T> consumer)

Setup additional message consumer.

Can be used to print all received messages to System.out

 subscriber.withMessageConsumer(System.out::println);
 

replay

public void replay(T item)

Description copied from class: SimpleSubscriber

Empty

Specified by:

replay in interface ReplayableSubscriber<T>

Overrides:

replay in class SimpleSubscriber<T>

onSubscribe

public void onSubscribe(Flow.Subscription subscription)
                 throws PreconditionException

Description copied from class: SimpleSubscriber

Saves subscription and requests SimpleSubscriber.withInitialRequest(int) number of items.

Specified by:

onSubscribe in interface Flow.Subscriber<T>

Overrides:

onSubscribe in class SimpleSubscriber<T>

Throws:

PreconditionException - if subscriber is already subscribed

onNext

public void onNext(T item)

Description copied from class: SimpleSubscriber

Empty

Specified by:

onNext in interface Flow.Subscriber<T>

Overrides:

onNext in class SimpleSubscriber<T>

getFuture

public Future<C> getFuture()