reactor.function.support

Class DelegatingConsumer<T>

java.lang.Object

reactor.function.support.DelegatingConsumer<T>

All Implemented Interfaces:

java.lang.Iterable<Consumer<T>>, BatchConsumer<T>, Consumer<T>

public class DelegatingConsumer<T>
extends java.lang.Object
implements BatchConsumer<T>, java.lang.Iterable<Consumer<T>>

An implementation of Consumer that maintains a list of delegates to which events received by this Consumer will be passed along.

NOTE: Access to the list of delegates is synchronized to make it thread-safe, so using this implementation of Consumer will incur an overall performance hit on throughput. Also, references to the Consumers are weak. It's not possible to remove a Consumer without a reference to it, so the DelegatingConsumer assumes references to Consumers added here have other components with strong references to them somewhere else.

Constructor Summary

Constructors

Constructor and Description
DelegatingConsumer()

Method Summary

Modifier and Type	Method and Description
void	accept(T t) Execute the logic of the action, accepting the given parameter.
DelegatingConsumer<T>	add(java.util.Collection<Consumer<T>> consumers) Add the given Consumers to the list of delegates.
DelegatingConsumer<T>	add(Consumer<T> consumer) Add the given Consumer to the list of delegates.
DelegatingConsumer<T>	clear() Clear all delegate Consumers from the list.
void	end() Called when a batch ends.
java.util.Iterator<Consumer<T>>	iterator()
DelegatingConsumer<T>	prune() Remove the references to Consumers that have been removed or have gone out of scope and prune the size of the list.
DelegatingConsumer<T>	remove(java.util.Collection<Consumer<T>> consumers) Remove the given Consumers from the list of delegates.
DelegatingConsumer<T>	remove(Consumer<T> consumer) Remove the given Consumer from the list of delegates.
void	start() Called when a batch begins.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

DelegatingConsumer

public DelegatingConsumer()

Method Detail

add

public DelegatingConsumer<T> add(Consumer<T> consumer)

Add the given Consumer to the list of delegates.

Parameters:

consumer - the Consumer to add

Returns:

this

add

public DelegatingConsumer<T> add(java.util.Collection<Consumer<T>> consumers)

Add the given Consumers to the list of delegates.

Parameters:

consumers - the Consumers to add

Returns:

this

remove

public DelegatingConsumer<T> remove(Consumer<T> consumer)

Remove the given Consumer from the list of delegates.

Parameters:

consumer -

Returns:

this

remove

public DelegatingConsumer<T> remove(java.util.Collection<Consumer<T>> consumers)

Remove the given Consumers from the list of delegates.

Parameters:

consumers - the Consumers to remove

Returns:

this

prune

public DelegatingConsumer<T> prune()

Remove the references to Consumers that have been removed or have gone out of scope and prune the size of the list. If many Consumers are removed individually, it will increase overall throughput to call this method periodically. To maintain as high a throughput as possible, though, its not necessary to call this every time a Consumer is removed.

Returns:

this

clear

public DelegatingConsumer<T> clear()

Clear all delegate Consumers from the list.

Returns:

this

accept

public 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.

iterator

@Nonnull
public java.util.Iterator<Consumer<T>> iterator()

Specified by:

iterator in interface java.lang.Iterable<Consumer<T>>

start

public void start()

Description copied from interface: BatchConsumer

Called when a batch begins.

Specified by:

start in interface BatchConsumer<T>

end

public void end()

Description copied from interface: BatchConsumer

Called when a batch ends.

Specified by:

end in interface BatchConsumer<T>