Package | Description |
---|---|
reactor.bus |
Hold the required abstraction to enable Event Driven Programming with Reactor.
|
reactor.bus.publisher | |
reactor.bus.support | |
reactor.groovy.ext | |
reactor.groovy.support |
Modifier and Type | Class and Description |
---|---|
class |
EventBus
|
Modifier and Type | Method and Description |
---|---|
Bus |
EventBus.ReplyToEvent.getReplyToObservable() |
Bus |
Bus.notify(Object key,
T ev)
Notify this component that an
Event is ready to be processed. |
Modifier and Type | Method and Description |
---|---|
EventBus |
EventBus.send(Object key,
Event<?> ev,
Bus replyTo)
|
EventBus |
EventBus.send(Object key,
Supplier<? extends Event<?>> supplier,
Bus replyTo)
|
Constructor and Description |
---|
BusPublisher(Bus<T> observable,
Selector selector) |
Constructor and Description |
---|
NotifyConsumer(Object notifyKey,
Bus<?> observable)
Creates a new
NotifyConsumer that will notify the given observable using
the given notifyKey . |
Modifier and Type | Method and Description |
---|---|
static Bus |
BusExtensions.notify(Bus selfType,
Map params) |
static Bus |
BusExtensions.notify(Bus selfType,
Object key) |
static <T> Bus |
BusExtensions.notify(Bus selfType,
Object key,
Supplier<Event<T>> obj) |
static <T> Bus |
BusExtensions.notify(Bus selfType,
Object key,
T obj) |
static <T> Bus |
BusExtensions.notify(Bus selfType,
String key,
groovy.lang.Closure<T> closure) |
Modifier and Type | Method and Description |
---|---|
static Bus |
BusExtensions.notify(Bus selfType,
Map params) |
static Bus |
BusExtensions.notify(Bus selfType,
Object key) |
static <T> Bus |
BusExtensions.notify(Bus selfType,
Object key,
Supplier<Event<T>> obj) |
static <T> Bus |
BusExtensions.notify(Bus selfType,
Object key,
T obj) |
static <T> Bus |
BusExtensions.notify(Bus selfType,
String key,
groovy.lang.Closure<T> closure) |
Modifier and Type | Method and Description |
---|---|
Bus |
ClosureEventConsumer.ReplyDecorator.getObservable() |
Constructor and Description |
---|
ReplyDecorator(Object replyTo,
Bus observable) |
Copyright © 2017. All rights reserved.