phaser.dsl — userevents/phaser 1.1.5

after clj multimethod

Create a group of event handlers/processors to be used as a dependency.

and clj multimethod

Create a new event handler group that combines the consumers in this group with otherHandlerGroup.

as-sequence-barrier clj

(as-sequence-barrier group)

Create a dependency barrier for the processors in this group.

create-disruptor clj

(create-disruptor event-factory size exec)

(create-disruptor event-factory size exec producer-type wait-strategy)

Create a new disruptor pattern

get-barrier-for clj

(get-barrier-for disruptor handler)

Get the SequenceBarrier used by a specific handler.

get-ring-buffer clj

(get-ring-buffer disruptor)

The RingBuffer used by this Disruptor.

halt clj

(halt disruptor)

Calls EvenProcessor.halt() on all of the event processors created via this Disruptor.

handle-events-with clj multimethod

Set up batch handlers to handle events from the ring buffer.

handle-events-with-worker-pool clj multimethod

Set up a worker pool to handle events from the ring buffer.

handle-exceptions-with clj

(handle-exceptions-with disruptor exception-handler)

Specify an exception handler to be used for any future event handlers.

Note that only event handlers set up after calling this method will use the exception handler.

shutdown clj

(shutdown disruptor)

Waits until all events currently in the disruptor have been processed by all event processors and then halts the processors.

start clj

(start disruptor)

Starts the event processors and returns the fully configured RingBuffer. The RingBuffer is set up to prevent overwriting any entry that is yet to be processed by the slowest event processor. This method must only be called one after all the event processors have been added.

then clj

(then group & handlers)

Set up batch handlers to consume events from the ring buffer.