Package energy.eddie.regionconnector.shared.event.sourcing

Class EventBusImpl

java.lang.Object

energy.eddie.regionconnector.shared.event.sourcing.EventBusImpl

All Implemented Interfaces:

EventBus, AutoCloseable

public class EventBusImpl
extends Object
implements EventBus, AutoCloseable

Constructor Summary

Constructors

Constructor	Description
EventBusImpl()

Method Summary

Modifier and Type	Method	Description
void	close()
void	emit(PermissionEvent event)	Emit an event via the EventBus.
reactor.core.publisher.Flux<PermissionEvent>	filteredFlux(PermissionProcessStatus status)	Get all events of a specific PermissionProcessStatus.
<T extends PermissionEvent> reactor.core.publisher.Flux<T>	filteredFlux(Class<T> clazz)	Get all events of a specific type.

Methods inherited from class java.lang.Object

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

Constructor Details

EventBusImpl

public EventBusImpl()

Method Details

emit

public void emit(PermissionEvent event)

Description copied from interface: EventBus

Emit an event via the EventBus. Every subscriber to this event will get the event.

Specified by:

emit in interface EventBus

Parameters:

event - event to be emitted

filteredFlux

public <T extends PermissionEvent>
reactor.core.publisher.Flux<T> filteredFlux(Class<T> clazz)

Description copied from interface: EventBus

Get all events of a specific type.

Specified by:

filteredFlux in interface EventBus

Type Parameters:

T - the type of the event

Parameters:

clazz - the class of the events.

Returns:

a flux, which streams the subscribed events.

filteredFlux

public reactor.core.publisher.Flux<PermissionEvent> filteredFlux(PermissionProcessStatus status)

Description copied from interface: EventBus

Get all events of a specific PermissionProcessStatus.

Specified by:

filteredFlux in interface EventBus

Parameters:

status - the PermissionProcessStatus of the event.

Returns:

a flux, which streams the subscribed events.

close

public void close()

Specified by:

close in interface AutoCloseable