Liking cljdoc? Tell your friends :D

qbits.tape.tailer


->tailer-direction

source

ITailerprotocol

index
(index tailer)

Returns current tailer index

Returns current tailer index

queue
(queue tailer)

Returns Queue associated with that tailer

Returns Queue associated with that tailer

read!
(read! tailer)

Returns message from queue or nil if none are available

Returns message from queue or nil if none are available

set-direction!
(set-direction! tailer dir)

Set tailer direction from :backward or :forward

Set tailer direction from :backward or :forward

to-end!
(to-end! tailer)

Goto the end of the queue

Goto the end of the queue

to-index!
(to-index! tailer i)

Goto specified queue index

Goto specified queue index

to-start!
(to-start! tailer)

Set index to the start of the queue

Set index to the start of the queue

source

make

(make queue)
(make queue {:keys [poll-interval], :or {poll-interval 50}})

Creates a new tailer that can consume a queue instance. Takes a queue to read from as first argument.

poll-interval will set the wait interval the tailer will apply when used in a reducible or seq context only when there are no new message ready to be consumed.

clojure.datafy/datafy can be called on the tailer to get associated data

A tailer can also be consumed as a Seq or a Reducible.

You can effectively do (doseq [msg tailer] ...) or (run! #(do-something %) tailer).

More info about tailers : https://github.com/OpenHFT/Chronicle-Queue#how-does-chronicle-queue-work

Creates a new tailer that can consume a queue instance. Takes a queue
to read from as first argument.

`poll-interval` will set the wait interval the tailer will apply
when used in a reducible or seq context only when there are no new
message ready to be consumed.

clojure.datafy/datafy can be called on the tailer to get associated data

A tailer can also be consumed as a Seq or a Reducible.

You can effectively do `(doseq [msg tailer] ...)` or `(run!
#(do-something %) tailer)`.

More info about tailers :
https://github.com/OpenHFT/Chronicle-Queue#how-does-chronicle-queue-work
sourceraw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close