An EventBus implementation that uses RxJava
Modifiers | Name | Description |
---|---|---|
protected java.util.Map<java.lang.CharSequence, PublishSubject> |
subjects |
Fields inherited from class | Fields |
---|---|
class AbstractEventBus |
subscriptions |
Constructor and description |
---|
RxEventBus
(Scheduler scheduler = Schedulers.io() |
Type Params | Return Type | Name and description |
---|---|---|
|
protected ClosureSubscription |
buildClosureSubscription(java.lang.CharSequence eventId, groovy.lang.Closure subscriber) |
|
protected java.util.concurrent.Callable |
buildNotificationCallable(Event event, java.util.Collection<Subscription> eventSubscriptions, groovy.lang.Closure reply) |
|
protected EventSubscriberSubscription |
buildSubscriberSubscription(java.lang.CharSequence eventId, Subscriber subscriber) |
Methods inherited from class | Name |
---|---|
class AbstractEventBus |
buildClosureSubscription, buildNotificationCallable, buildNotificationTrigger, buildSubscriberSubscription, isActive, notify, notify, notify, on, publish, publish, publish, sendAndReceive, sendAndReceive, subscribe, subscribe, unsubscribeAll |