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	RateLimitingPredicate.accept(java.lang.Object[] elements, Sink 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	NullEnqueuePredicate.accept(java.lang.Object[] element, Sink modifyingSink)
boolean	RateLimitingPredicate.accept(java.lang.Object element, Sink sink)
boolean	ThresholdEnqueuePredicate.accept(java.lang.Object element, Sink modifyingSink) Returns true if the Sink size + 1 (the element) is less than the threshold.
boolean	NullEnqueuePredicate.accept(java.lang.Object element, Sink modifyingSink)
private boolean	ThresholdEnqueuePredicate.testThreshold(Sink modifyingSink, int numElements)