flowgraph.protocols — com.workiva/flowgraph 0.1.1

*thread-capacity* clj

Flow clj protocol

shutdown clj

(shutdown this)

submit clj

(submit this stuff)

Returns a tessera

GuardedQueue clj protocol

peek clj

(peek _)

Peek at the next raw item in the underlying queue. Be careful -- this doesn't behave analogously to pop.

raw-size clj

(raw-size _)

Returns the number of raw things in the queue...regardless of batching semantics

push-deferred-batch clj

(push-deferred-batch _ guard deferred-batch)

Pushes into the queue a deferred item that represents a batch of results.

ready? clj

(ready? _)

Ready to spit out an item at least if forced.

push-batch clj

(push-batch _ guard batch)

Pushes a batch of regular values into the queue.

push clj

(push _ guard item)

Pushes a regular value into the queue.

pop clj

(pop _ guard)

(pop _ guard force?)

Requests item from queue. If force? is true, this yields items the queue might otherwise wish to hold on to.

drain clj

(drain _ guard)

Returns a sequence of all the items from this queue.

set-guard! clj

(set-guard! _ guard)

Sets the guard and empties the queue. Operations performed with any other guard will fail silently (what could possibly go wrong?).

push-deferred clj

(push-deferred _ guard deferred-item)

Pushes a deferred item into the queue.