Uses of Interface
org.d_haven.event.Sink

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)