RxEventBus (Grace Events Framework

org.grails.events.rxjava.RxEventBus

```
@CompileStatic
@Slf4j
class RxEventBus
extends AbstractEventBus
```
An EventBus implementation that uses RxJava
Authors:
Graeme Rocher
Since:
3.3

Field Summary

Fields
Modifiers	Name	Description
`protected Map<CharSequence, PublishSubject>`	`subjects`

Inherited fields
Fields inherited from class	Fields
`class AbstractEventBus`	`subscriptions`

Properties Summary

Properties
Type	Name and description
`Scheduler`	`scheduler`

Constructor Summary

Constructors
Constructor and description
`RxEventBus(Scheduler scheduler)`

Methods Summary

Methods
Type Params	Return Type	Name and description
	`protected ClosureSubscription`	`buildClosureSubscription(CharSequence eventId, Closure subscriber)`
	`protected Callable`	`buildNotificationCallable(Event event, Collection<Subscription> eventSubscriptions, Closure reply)`
	`protected EventSubscriberSubscription`	`buildSubscriberSubscription(CharSequence eventId, Subscriber subscriber)`

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class AbstractEventBus`	`buildClosureSubscription, buildNotificationCallable, buildNotificationTrigger, buildSubscriberSubscription, isActive, notify, notify, notify, on, publish, publish, publish, sendAndReceive, sendAndReceive, subscribe, subscribe, unsubscribeAll`

- Field Detail
  - protected final Map<CharSequence, PublishSubject> subjects
- Property Detail
  - final Scheduler scheduler
- Constructor Detail
  - RxEventBus(Scheduler scheduler)
- Method Detail
  - @Override
    protected ClosureSubscription buildClosureSubscription(CharSequence eventId, Closure subscriber)
  - @Override
    protected Callable buildNotificationCallable(Event event, Collection<Subscription> eventSubscriptions, Closure reply)
  - @Override
    protected EventSubscriberSubscription buildSubscriberSubscription(CharSequence eventId, Subscriber subscriber)

Summary:
Field
Property
Constructor
Method

Groovy Documentation

[Groovy] Class RxEventBus

Field Summary

Properties Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

protected final Map<CharSequence, PublishSubject> subjects

Property Detail

final Scheduler scheduler

Constructor Detail

RxEventBus(Scheduler scheduler)

Method Detail

@Override
protected ClosureSubscription buildClosureSubscription(CharSequence eventId, Closure subscriber)

@Override
protected Callable buildNotificationCallable(Event event, Collection<Subscription> eventSubscriptions, Closure reply)

@Override
protected EventSubscriberSubscription buildSubscriberSubscription(CharSequence eventId, Subscriber subscriber)

[Groovy] Class RxEventBus

Field Summary

Properties Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

protected final Map<CharSequence, PublishSubject> subjects

Property Detail

final Scheduler scheduler

Constructor Detail

RxEventBus(Scheduler scheduler)

Method Detail

@Overrideprotected ClosureSubscription buildClosureSubscription(CharSequence eventId, Closure subscriber)

@Overrideprotected Callable buildNotificationCallable(Event event, Collection<Subscription> eventSubscriptions, Closure reply)

@Overrideprotected EventSubscriberSubscription buildSubscriberSubscription(CharSequence eventId, Subscriber subscriber)

@Override
protected ClosureSubscription buildClosureSubscription(CharSequence eventId, Closure subscriber)

@Override
protected Callable buildNotificationCallable(Event event, Collection<Subscription> eventSubscriptions, Closure reply)

@Override
protected EventSubscriberSubscription buildSubscriberSubscription(CharSequence eventId, Subscriber subscriber)