|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Sink | |
---|---|
org.d_haven.event | |
org.d_haven.event.command | |
org.d_haven.event.impl |
Uses of Sink in org.d_haven.event |
---|
Subinterfaces of Sink in org.d_haven.event | |
---|---|
interface |
Pipe
A Source implements the side of an event queue where QueueElements are dequeued operations only. |
Methods in org.d_haven.event with parameters of type Sink | |
---|---|
boolean |
EnqueuePredicate.accept(java.lang.Object[] elements,
Sink modifyingSink)
Tests the given element for acceptance onto the m_sink. |
boolean |
EnqueuePredicate.accept(java.lang.Object element,
Sink modifyingSink)
Tests the given element for acceptance onto the m_sink. |
Uses of Sink in org.d_haven.event.command |
---|
Methods in org.d_haven.event.command that return Sink | |
---|---|
Sink |
CommandEventPipeline.getIncomingSink()
Provide a way to get the Sink to send new Commands to. |
Sink |
CommandEventPipeline.getRecurringSink()
Provide a way to get the Sink to requeue delayed Commands to. |
Methods in org.d_haven.event.command with parameters of type Sink | |
---|---|
boolean |
SwitchedEnqueuePredicate.accept(java.lang.Object[] elements,
Sink modifyingSink)
Tests the given element for acceptance onto the m_sink. |
boolean |
SwitchedEnqueuePredicate.accept(java.lang.Object element,
Sink modifyingSink)
Tests the given element for acceptance onto the m_sink. |
Uses of Sink in org.d_haven.event.impl |
---|
Classes in org.d_haven.event.impl that implement Sink | |
---|---|
class |
AbstractPipe
Provides the base functionality for the other Pipe
types. |
class |
DefaultPipe
The default queue implementation is a variable size queue. |
class |
MultiCastSink
This is a Sink implementation that
multicasts enqueue operations to the contained and concrete sink
objects. |
Methods in org.d_haven.event.impl with parameters of type Sink | |
---|---|
boolean |
ThresholdEnqueuePredicate.accept(java.lang.Object[] elements,
Sink modifyingSink)
Returns true if the Sink size + the number of elements is less than the threshold. |
boolean |
RateLimitingPredicate.accept(java.lang.Object[] elements,
Sink sink)
|
boolean |
NullEnqueuePredicate.accept(java.lang.Object[] element,
Sink modifyingSink)
|
boolean |
ThresholdEnqueuePredicate.accept(java.lang.Object element,
Sink modifyingSink)
Returns true if the Sink size + 1 (the element) is less than the threshold. |
boolean |
RateLimitingPredicate.accept(java.lang.Object element,
Sink sink)
|
boolean |
NullEnqueuePredicate.accept(java.lang.Object element,
Sink modifyingSink)
|
private boolean |
ThresholdEnqueuePredicate.testThreshold(Sink modifyingSink,
int numElements)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |