reactor.function.support

Class Tap<T>

java.lang.Object

reactor.function.support.Tap<T>

Type Parameters:

T - the type of values that this Tap can consume and supply

All Implemented Interfaces:

Consumer<T>, Supplier<T>

public class Tap<T>
extends java.lang.Object
implements Consumer<T>, Supplier<T>

A Tap provides a limited window into an event stream. Using a Tap one can inspect the current event passing through a stream. A Tap's value will be continually updated as data passes through the stream, so a call to get() will return the last value seen by the event stream.

Constructor Summary

Constructors

Constructor and Description
Tap() Create a Tap.

Method Summary

Modifier and Type	Method and Description
void	accept(T value) Execute the logic of the action, accepting the given parameter.
T	get() Get the value of this Tap, which is the current value of the event stream this tap is consuming.

Methods inherited from class java.lang.Object

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

Constructor Detail

Tap

public Tap()

Create a Tap.

Method Detail

get

public T get()

Get the value of this Tap, which is the current value of the event stream this tap is consuming.

Specified by:

get in interface Supplier<T>

Returns:

the value

accept

public void accept(T value)

Description copied from interface: Consumer

Execute the logic of the action, accepting the given parameter.

Specified by:

accept in interface Consumer<T>

Parameters:

value - The parameter to pass to the consumer.