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.spec |
Specs help create
Reactors by providing a fluent API to specify
common options. |
reactor.groovy.config | |
reactor.io.net.http |
Components for writing HTTP-based clients and servers using Reactor abstractions.
|
Modifier and Type | Method and Description |
---|---|
Registry<Object,Consumer<? extends Event<?>>> |
EventBus.getConsumerRegistry()
|
Constructor and Description |
---|
EventBus(Registry<Object,Consumer<? extends Event<?>>> consumerRegistry,
Dispatcher dispatcher,
Router router,
Consumer<Throwable> dispatchErrorHandler,
Consumer<Throwable> uncaughtErrorHandler)
Create a new Reactor that uses the given
dispatacher and eventRouter . |
Modifier and Type | Class and Description |
---|---|
class |
CachingRegistry<K,V>
Implementation of
Registry that uses a partitioned cache that partitions on thread
id. |
class |
SimpleCachingRegistry<K,V>
A naive caching Registry implementation for use in situations that the default
CachingRegistry can't be used
due to its reliance on the gs-collections library. |
Modifier and Type | Method and Description |
---|---|
static <K,V> Registry<K,V> |
Registries.create() |
static <K,V> Registry<K,V> |
Registries.create(boolean useCache,
boolean cacheNotFound,
Consumer<K> onNotFound) |
Modifier and Type | Method and Description |
---|---|
SPEC |
EventRoutingComponentSpec.consumerRegistry(Registry<Object,Consumer<? extends Event<?>>> consumerRegistry)
Configures the
Registry to use when creating this component. |
Constructor and Description |
---|
StreamRouter(Filter filter,
Registry<Object,org.reactivestreams.Processor<Event<?>,Event<?>>> processorRegistry) |
Modifier and Type | Field and Description |
---|---|
protected Registry<HttpChannel,ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>>> |
HttpServer.routedWriters |
Copyright © 2016. All rights reserved.