Package io.socket.engineio.server

Class Emitter

java.lang.Object

io.socket.engineio.server.Emitter

Direct Known Subclasses:

EngineIoServer, EngineIoSocket, EngineIoWebSocket, Transport

public class Emitter
extends java.lang.Object

The event emitter which is ported from the JavaScript module. This class is thread-safe.

See Also:

https://github.com/component/emitter

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	Emitter.Listener
private class	Emitter.OnceListener

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.concurrent.ConcurrentMap<java.lang.String,java.util.concurrent.ConcurrentLinkedQueue<Emitter.Listener>>	mCallbacks

Constructor Summary

Constructors

Constructor	Description
Emitter()

Method Summary

Modifier and Type	Method	Description
Emitter	emit(java.lang.String event, java.lang.Object... args)	Executes each of listeners with the given args.
boolean	hasListeners(java.lang.String event)	Check if this emitter has listeners for the specified event.
java.util.List<Emitter.Listener>	listeners(java.lang.String event)	Returns a list of listeners for the specified event.
Emitter	off()	Removes all registered listeners.
Emitter	off(java.lang.String event)	Removes all listeners of the specified event.
Emitter	off(java.lang.String event, Emitter.Listener fn)	Removes the listener.
Emitter	on(java.lang.String event, Emitter.Listener fn)	Listens on the event.
Emitter	once(java.lang.String event, Emitter.Listener fn)	Adds a one time listener for the event.
private static boolean	sameAs(Emitter.Listener fn, Emitter.Listener internal)

Methods inherited from class java.lang.Object

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

Field Detail

mCallbacks

private final java.util.concurrent.ConcurrentMap<java.lang.String,java.util.concurrent.ConcurrentLinkedQueue<Emitter.Listener>> mCallbacks

Constructor Detail

Emitter

public Emitter()

Method Detail

on

public Emitter on(java.lang.String event,
                  Emitter.Listener fn)

Listens on the event.

Parameters:

event - event name.

fn - Event listener.

Returns:

a reference to this object.

once

public Emitter once(java.lang.String event,
                    Emitter.Listener fn)

Adds a one time listener for the event.

Parameters:

event - an event name.

fn - Event listener.

Returns:

a reference to this object.

off

public Emitter off()

Removes all registered listeners.

Returns:

a reference to this object.

off

public Emitter off(java.lang.String event)

Removes all listeners of the specified event.

Parameters:

event - an event name.

Returns:

a reference to this object.

off

public Emitter off(java.lang.String event,
                   Emitter.Listener fn)

Removes the listener.

Parameters:

event - an event name.

fn - Event listener.

Returns:

a reference to this object.

emit

public Emitter emit(java.lang.String event,
                    java.lang.Object... args)

Executes each of listeners with the given args.

Parameters:

event - an event name.

args - Data to emit.

Returns:

a reference to this object.

listeners

public java.util.List<Emitter.Listener> listeners(java.lang.String event)

Returns a list of listeners for the specified event. The returned list is not modifiable.

Parameters:

event - an event name.

Returns:

a reference to this object.

hasListeners

public boolean hasListeners(java.lang.String event)

Check if this emitter has listeners for the specified event.

Parameters:

event - an event name.

Returns:

a reference to this object.

sameAs

private static boolean sameAs(Emitter.Listener fn,
                              Emitter.Listener internal)