reactor.function.support

Class SingleUseConsumer<T>

java.lang.Object

reactor.function.support.SingleUseConsumer<T>

Type Parameters:

T - the type of the values that the consumer can accept

All Implemented Interfaces:

Consumer<T>

public class SingleUseConsumer<T>
extends java.lang.Object
implements Consumer<T>

A Consumer implementation that allows the delegate Consumer to only be called once. Should be used in combination with Registration.cancelAfterUse() to ensure that this Consumer's Registration is cancelled as soon after its use as possible.

Constructor Summary

Constructors

Constructor and Description
SingleUseConsumer() Used to create anonymous subclasses.
SingleUseConsumer(Consumer<T> delegate) Create a single-use Consumer using the given delgate.

Method Summary

Modifier and Type	Method and Description
void	accept(T t) Execute the logic of the action, accepting the given parameter.
protected void	doAccept(T t)
static <T> Consumer<T>	once(Consumer<T> delegate) Static helper method for creating SingleUseConsumer SingleUseConsumers in code with a little less noise.

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleUseConsumer

public SingleUseConsumer()

Used to create anonymous subclasses.

SingleUseConsumer

public SingleUseConsumer(Consumer<T> delegate)

Create a single-use Consumer using the given delgate.

Parameters:

delegate - The Consumer to delegate accept calls to.

Method Detail

once

public static <T> Consumer<T> once(Consumer<T> delegate)

Static helper method for creating SingleUseConsumer SingleUseConsumers in code with a little less noise.

Type Parameters:

T - Type of the Consumer's argument.

Parameters:

delegate - The delegate Consumer to invoke.

Returns:

A new Consumer that will only be invoked once, then cancelled.

accept

public final void accept(T t)

Description copied from interface: Consumer

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

Specified by:

accept in interface Consumer<T>

Parameters:

t - The parameter to pass to the consumer.

doAccept

protected void doAccept(T t)