com.lambdaworks.redis.event

Interface EventBus

All Known Implementing Classes:

DefaultEventBus

public interface EventBus

Interface for an EventBus. Events can be published over the bus that are delivered to the subscribers.

Since:

3.4

Author:

Mark Paluch

Method Summary

Modifier and Type	Method and Description
rx.Observable<Event>	get() Subscribe to the event bus and Events.
void	publish(Event event) Publish a Event to the bus.

Method Detail

get

rx.Observable<Event> get()

Subscribe to the event bus and Events. The Observable drops events on backpressure to avoid contention.

Returns:

the observable to obtain events.

publish

void publish(Event event)

Publish a Event to the bus.

Parameters:

event - the event to publish