com.github.lero4ka16.ef4j

Class AbstractEventBus

java.lang.Object

com.github.lero4ka16.ef4j.AbstractEventBus

All Implemented Interfaces:

EventBus, EventNamespace

Direct Known Subclasses:

ConcurrentEventBus, SimpleEventBus, SyncEventBus

public abstract class AbstractEventBus
extends java.lang.Object
implements EventBus

Constructor Summary

Constructors

Constructor and Description
AbstractEventBus(boolean isSynchronized, java.util.Map<EventNamespace,java.util.Set<EventSubscription<?>>> byNamespace, java.util.Map<java.lang.reflect.Type,com.github.lero4ka16.ef4j.EventSubscriptionStorage<?>> byEvent, java.util.function.Supplier<java.util.Set<EventSubscription<?>>> byNamespaceSetFactory)

Method Summary

Modifier and Type	Method and Description
void	publish(Event event)
protected void	register(EventSubscription<? extends Event> subscription)
EventObjectSubscription	subscribe(EventNamespace namespace, java.lang.Object listener)
EventObjectSubscription	subscribe(java.lang.Object listener)
void	unsubscribe(EventObjectSubscription objectSubscription)
void	unsubscribe(EventSubscription<?> subscription)
void	unsubscribeAll()
void	unsubscribeAll(EventNamespace namespace)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractEventBus

public AbstractEventBus(boolean isSynchronized,
                        java.util.Map<EventNamespace,java.util.Set<EventSubscription<?>>> byNamespace,
                        java.util.Map<java.lang.reflect.Type,com.github.lero4ka16.ef4j.EventSubscriptionStorage<?>> byEvent,
                        java.util.function.Supplier<java.util.Set<EventSubscription<?>>> byNamespaceSetFactory)

Method Detail

unsubscribe

public void unsubscribe(EventSubscription<?> subscription)

Specified by:

unsubscribe in interface EventBus

unsubscribeAll

public void unsubscribeAll(EventNamespace namespace)

Specified by:

unsubscribeAll in interface EventBus

unsubscribeAll

public void unsubscribeAll()

Specified by:

unsubscribeAll in interface EventBus

publish

public void publish(Event event)

Specified by:

publish in interface EventBus

register

protected void register(EventSubscription<? extends Event> subscription)

subscribe

public EventObjectSubscription subscribe(EventNamespace namespace,
                                         java.lang.Object listener)

Specified by:

subscribe in interface EventBus

subscribe

public EventObjectSubscription subscribe(java.lang.Object listener)

Specified by:

subscribe in interface EventBus

unsubscribe

public void unsubscribe(EventObjectSubscription objectSubscription)

Specified by:

unsubscribe in interface EventBus