| Package | Description |
|---|---|
| org.fusesource.hawtdispatch |
HawtDispatch
|
| org.fusesource.hawtdispatch.internal |
| Modifier and Type | Interface and Description |
|---|---|
interface |
OrderedEventAggregator<Event,MergedEvent>
This class should be implemented by Aggregator classes which
depend on FIFO ordering of events from the point of view of
the serial queue which merges events into it.
|
| Modifier and Type | Field and Description |
|---|---|
static EventAggregator<java.lang.Integer,java.lang.Integer> |
EventAggregators.INTEGER_ADD
An EventAggregator that coalesces integer data obtained via calls to
CustomDispatchSource.merge(Object). |
static EventAggregator<java.lang.Integer,java.lang.Integer> |
EventAggregators.INTEGER_OR
An EventAggregator that coalesces integer data obtained via calls to
CustomDispatchSource.merge(Object). |
static EventAggregator<java.lang.Long,java.lang.Long> |
EventAggregators.LONG_ADD
An EventAggregator that coalesces long data obtained via calls to
CustomDispatchSource.merge(Object). |
static EventAggregator<java.lang.Long,java.lang.Long> |
EventAggregators.LONG_OR
An EventAggregator that coalesces long data obtained via calls to
CustomDispatchSource.merge(Object). |
| Modifier and Type | Method and Description |
|---|---|
static <T> EventAggregator<T,java.util.HashSet<T>> |
EventAggregators.hashSet()
An EventAggregator that coalesces object data obtained via calls to
CustomDispatchSource.merge(Object) into a hash set. |
static <T> EventAggregator<T,java.util.LinkedList<T>> |
EventAggregators.linkedList()
An EventAggregator that coalesces object data obtained via calls to
CustomDispatchSource.merge(Object) into a linked list. |
| Modifier and Type | Method and Description |
|---|---|
static <Event,MergedEvent> |
Dispatch.createSource(EventAggregator<Event,MergedEvent> aggregator,
DispatchQueue queue)
Creates a new
CustomDispatchSource to monitor events merged into
the dispatch source and automatically submit a handler runnable to a dispatch queue
in response to the events. |
<Event,MergedEvent> |
Dispatcher.createSource(EventAggregator<Event,MergedEvent> aggregator,
DispatchQueue queue)
Creates a new
CustomDispatchSource to monitor events merged into
the dispatch source and automatically submit a handler runnable to a dispatch queue
in response to the events. |
| Modifier and Type | Field and Description |
|---|---|
private EventAggregator<Event,MergedEvent> |
HawtCustomDispatchSource.aggregator |
| Modifier and Type | Method and Description |
|---|---|
<Event,MergedEvent> |
HawtDispatcher.createSource(EventAggregator<Event,MergedEvent> aggregator,
DispatchQueue queue) |
| Constructor and Description |
|---|
HawtCustomDispatchSource(HawtDispatcher dispatcher,
EventAggregator<Event,MergedEvent> aggregator,
DispatchQueue queue) |