Package | Description |
---|---|
reactor.bus |
Hold the required abstraction to enable Event Driven Programming with Reactor.
|
reactor.bus.spec |
Specs help create
Reactors by providing a fluent API to specify
common options. |
reactor.groovy.config | |
reactor.groovy.ext |
Modifier and Type | Method and Description |
---|---|
static EventBus |
EventBus.create()
Create a new synchronous
EventBus |
static EventBus |
EventBus.create(Dispatcher dispatcher)
Create a new
EventBus using the given Dispatcher . |
static EventBus |
EventBus.create(Environment env)
Create a new
EventBus using the given Environment . |
static EventBus |
EventBus.create(Environment env,
Dispatcher dispatcher)
|
static EventBus |
EventBus.create(Environment env,
String dispatcher)
Create a new
EventBus using the given Environment and dispatcher name. |
EventBus |
EventBus.notify(Object key)
Notify this component that the consumers registered with a
Selector that matches the key should be
triggered with a null input argument. |
EventBus |
EventBus.notify(Object key,
Event<?> ev) |
EventBus |
EventBus.notify(Object key,
Supplier<? extends Event<?>> supplier)
Notify this component that the given
Supplier can provide an event that's ready to be
processed. |
EventBus |
EventBus.notify(org.reactivestreams.Publisher<?> source,
Object key)
Pass values accepted by this
Stream into the given Bus , notifying with the given key. |
<T> EventBus |
EventBus.notify(org.reactivestreams.Publisher<? extends T> source,
Function<? super T,?> keyMapper)
Pass values accepted by this
Stream into the given Bus , notifying with the given key. |
EventBus |
EventBus.send(Object key,
Event<?> ev)
|
EventBus |
EventBus.send(Object key,
Event<?> ev,
Bus replyTo)
|
EventBus |
EventBus.send(Object key,
Supplier<? extends Event<?>> supplier)
|
EventBus |
EventBus.send(Object key,
Supplier<? extends Event<?>> supplier,
Bus replyTo)
|
<T extends Event<?>> |
EventBus.sendAndReceive(Object key,
Event<?> event,
Consumer<T> reply)
|
<T extends Event<?>> |
EventBus.sendAndReceive(Object key,
Supplier<? extends Event<?>> supplier,
Consumer<T> reply)
|
Modifier and Type | Method and Description |
---|---|
protected EventBus |
EventBusSpec.configure(EventBus reactor,
Environment environment) |
Modifier and Type | Method and Description |
---|---|
protected abstract TARGET |
EventRoutingComponentSpec.configure(EventBus reactor,
Environment environment) |
protected EventBus |
EventBusSpec.configure(EventBus reactor,
Environment environment) |
Modifier and Type | Method and Description |
---|---|
EventBus |
ReactorBuilder.get() |
EventBus |
GroovyEnvironment.getAt(String reactor) |
EventBus |
GroovyEnvironment.reactor(String reactor) |
EventBus |
GroovyEnvironment.reactor(String reactorName,
EventBus reactor) |
Modifier and Type | Method and Description |
---|---|
void |
GroovyEnvironment.putAt(String reactorName,
EventBus reactor) |
EventBus |
GroovyEnvironment.reactor(String reactorName,
EventBus reactor) |
Constructor and Description |
---|
NestedReactorBuilder(String reactorName,
ReactorBuilder parent,
EventBus reactor) |
ReactorBuilder(String name,
Map<String,ReactorBuilder> reactorMap,
EventBus reactor) |
Modifier and Type | Method and Description |
---|---|
static <T> EventBus |
BusExtensions.send(EventBus selfType,
Object key,
Event<T> obj,
groovy.lang.Closure handler) |
static <T> EventBus |
BusExtensions.send(EventBus selfType,
Object key,
T obj) |
static <T> EventBus |
BusExtensions.send(EventBus selfType,
Object key,
T obj,
groovy.lang.Closure handler) |
Modifier and Type | Method and Description |
---|---|
static <K,T> Registration<K,Consumer<T>> |
BusExtensions.react(EventBus selfType,
Selector<K> selector,
groovy.lang.Closure handler) |
static <T> Registration<String,Consumer<T>> |
BusExtensions.react(EventBus selfType,
String selector,
groovy.lang.Closure handler) |
static <T> void |
ReactorStaticExtensions.schedule(EventBus selfType,
T value,
groovy.lang.Closure closure) |
static <T> EventBus |
BusExtensions.send(EventBus selfType,
Object key,
Event<T> obj,
groovy.lang.Closure handler) |
static <T> EventBus |
BusExtensions.send(EventBus selfType,
Object key,
T obj) |
static <T> EventBus |
BusExtensions.send(EventBus selfType,
Object key,
T obj,
groovy.lang.Closure handler) |
Copyright © 2016. All rights reserved.