alluxio.master.transport

Class Listeners<T>

java.lang.Object

alluxio.master.transport.Listeners<T>

Type Parameters:

T - the listener type

All Implemented Interfaces:

Iterable<Listener<T>>

public class Listeners<T>
extends Object
implements Iterable<Listener<T>>

A class to hold all listeners belong to given type T.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	Listeners.ListenerHolder The listener holder with messaging context.

Constructor Summary

Constructors

Constructor and Description
Listeners() Empty constructor to construct Listeners.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	accept(T event) Accepts an event.
Listener<T>	add(java.util.function.Consumer<T> listener) Adds a new listener.
Iterator<Listener<T>>	iterator()
int	size()

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

Listeners

public Listeners()

Empty constructor to construct Listeners.

Method Detail

size

public int size()

Returns:

the current holding listeners

add

public Listener<T> add(java.util.function.Consumer<T> listener)

Adds a new listener.

Parameters:

listener - the listener to add

Returns:

listener holder of this listener

accept

public CompletableFuture<Void> accept(T event)

Accepts an event.

Parameters:

event - the event to accept

Returns:

the listener accepted future

iterator

public Iterator<Listener<T>> iterator()

Specified by:

iterator in interface Iterable<Listener<T>>