reactor.function.support

Class Poller<T>

java.lang.Object

reactor.function.support.Poller<T>

public class Poller<T>
extends java.lang.Object

A Poller funnels non-null values retrieved from a Supplier to the given Consumer using a separate thread created for each instance of a Poller.

Constructor Summary

Constructors

Constructor and Description
Poller(Supplier<T> supplier, Consumer<T> consumer) Poll the given Supplier for non-null values and pass them to the given Consumer.
Poller(Supplier<T> supplier, Consumer<T> consumer, boolean paused) Poll the given Supplier for non-null values and pass them to the given Consumer.

Method Summary

Modifier and Type	Method and Description
Poller<T>	pause() Pausing polling for values from this Supplier.
Poller<T>	resume() Resume polling values from the Supplier.
void	shutdown() Shutdown this Poller and stop the internal thread from polling the supplier.

Methods inherited from class java.lang.Object

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

Constructor Detail

Poller

public Poller(Supplier<T> supplier,
              Consumer<T> consumer)

Poll the given Supplier for non-null values and pass them to the given Consumer.

Parameters:

supplier - the Supplier to poll

consumer - the Consumer to pass values to

Poller

public Poller(Supplier<T> supplier,
              Consumer<T> consumer,
              boolean paused)

Poll the given Supplier for non-null values and pass them to the given Consumer. If paused is false, then don't start polling values from the supplier until resume() is invoked.

Parameters:

supplier - the Supplier to poll

consumer - the Consumer to pass values to

paused - whether to start this Poller in a paused state or not

Method Detail

resume

public Poller<T> resume()

Resume polling values from the Supplier.

Returns:

this

pause

public Poller<T> pause()

Pausing polling for values from this Supplier.

Returns:

this

shutdown

public void shutdown()

Shutdown this Poller and stop the internal thread from polling the supplier.