org.apache.giraph.function

Class ObjectNotifier<T>

java.lang.Object

org.apache.giraph.function.ObjectNotifier<T>

Type Parameters:

T - Argument type

All Implemented Interfaces:

Serializable, Consumer<T>, Notifier<T>

public class ObjectNotifier<T>
extends Object
implements Consumer<T>, Notifier<T>

Allows multiple Consumers to be combined into a single Consumer, by having them all subscribe to this object, and then using this object as a group Consumer.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ObjectNotifier()

Method Summary

Modifier and Type	Method and Description
void	apply(T value) Applies this function to input
void	subscribe(Consumer<T> consumer) Subscribe consumer to notifications on the given object.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ObjectNotifier

public ObjectNotifier()

Method Detail

apply

public void apply(T value)

Description copied from interface: Consumer

Applies this function to input

Specified by:

apply in interface Consumer<T>

Parameters:

value - Input

subscribe

public void subscribe(Consumer<T> consumer)

Description copied from interface: Notifier

Subscribe consumer to notifications on the given object.

Specified by:

subscribe in interface Notifier<T>

Parameters:

consumer - Consumer

toString

public String toString()

Overrides:

toString in class Object