Package | Description |
---|---|
reactor.bus |
Hold the required abstraction to enable Event Driven Programming with Reactor.
|
reactor.bus.registry |
Registries provide a common way to retrieve items registered using a
Selector . |
reactor.bus.routing | |
reactor.bus.timer | |
reactor.groovy.config | |
reactor.groovy.ext |
Modifier and Type | Method and Description |
---|---|
<T extends Event<?>> |
EventBus.on(Selector selector,
Consumer<T> consumer) |
<V extends T> |
Bus.on(Selector selector,
Consumer<V> consumer)
|
<T extends Event<?>,V> |
EventBus.receive(Selector sel,
Function<T,V> fn)
|
Modifier and Type | Class and Description |
---|---|
class |
CachableRegistration<K,V> |
Modifier and Type | Method and Description |
---|---|
Registration<K,V> |
Registration.cancel()
Cancel this Registration by removing it from its registry.
|
Registration<K,V> |
CachableRegistration.cancel() |
Registration<K,V> |
Registration.cancelAfterUse()
Cancel this
Registration after it has been selected and used. |
Registration<K,V> |
CachableRegistration.cancelAfterUse() |
Registration<K,V> |
Registration.pause()
Pause this Registration.
|
Registration<K,V> |
CachableRegistration.pause() |
Registration<K,V> |
CachingRegistry.register(Selector<K> sel,
V obj) |
Registration<K,V> |
SimpleCachingRegistry.register(Selector<K> sel,
V obj) |
Registration<K,V> |
Registry.register(Selector<K> sel,
V obj)
Assign the given
Selector with the given object. |
Registration<K,V> |
Registration.resume()
Unpause this Registration, making it available for
selection . |
Registration<K,V> |
CachableRegistration.resume() |
Modifier and Type | Method and Description |
---|---|
Iterator<Registration<K,? extends V>> |
CachingRegistry.iterator() |
Iterator<Registration<K,? extends V>> |
SimpleCachingRegistry.iterator() |
List<Registration<K,? extends V>> |
CachingRegistry.select(K key) |
List<Registration<K,? extends V>> |
SimpleCachingRegistry.select(K key) |
List<Registration<K,? extends V>> |
Registry.select(K key)
|
Modifier and Type | Method and Description |
---|---|
<E extends Event<?>> |
TraceableDelegatingRouter.route(Object key,
E event,
List<Registration<Object,? extends Consumer<? extends Event<?>>>> consumers,
Consumer<E> completionConsumer,
Consumer<Throwable> errorConsumer) |
<E extends Event<?>> |
ConsumerFilteringRouter.route(Object key,
E event,
List<Registration<Object,? extends Consumer<? extends Event<?>>>> consumers,
Consumer<E> completionConsumer,
Consumer<Throwable> errorConsumer) |
<E extends Event<?>> |
Router.route(Object key,
E data,
List<Registration<Object,? extends Consumer<? extends Event<?>>>> consumers,
Consumer<E> completionConsumer,
Consumer<Throwable> errorConsumer)
Routes the
event , triggered by a notification with the given key to the
consumers . |
Modifier and Type | Method and Description |
---|---|
Registration<Long,? extends Consumer<Long>> |
EventTimer.schedule(Consumer<Long> consumer,
long period,
TimeUnit timeUnit) |
Registration<Long,? extends Consumer<Long>> |
EventTimer.schedule(Consumer<Long> consumer,
long period,
TimeUnit timeUnit,
long delayInMilliseconds) |
Registration<Long,? extends Consumer<Long>> |
EventTimer.submit(Consumer<Long> consumer) |
Registration<Long,? extends Consumer<Long>> |
EventTimer.submit(Consumer<Long> consumer,
long delay,
TimeUnit timeUnit) |
Modifier and Type | Method and Description |
---|---|
<E extends Event<?>> |
StreamRouter.route(Object key,
E event,
List<Registration<Object,? extends Consumer<? extends Event<?>>>> consumers,
Consumer<E> completionConsumer,
Consumer<Throwable> errorConsumer) |
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) |
Copyright © 2017. All rights reserved.