exoscale.vinyl.cursor — com.exoscale/vinyl 0.1.25

Utilities to work with RecordCursor

apply-iterable-transduce clj

(apply-iterable-transduce async-iterable f init)

(apply-iterable-transduce async-iterable f init cont-fn)

(apply-iterable-transduce async-iterable xform f init cont-fn)

apply-transduce clj

(apply-transduce cursor f init)

(apply-transduce cursor f init cont-fn)

(apply-transduce cursor xform f init cont-fn)

A variant of RecordCursor::reduce that honors reduced? and supports transducers. Hopefully https://github.com/FoundationDB/fdb-record-layer/pull/1272 gets in which will provide a way to do this directly from record layer.

When cont-fn is given, it will be called on the last seen continuation byte array for every new element.

apply-transforms clj

(apply-transforms cursor
                  {:exoscale.vinyl.store/keys [list? skip limit transform
                                               reduce-init transducer reducer
                                               filter foreach iterator?]})

Apply transformations to a record cursor.

CursorHolder clj protocol

as-iterator clj

(as-iterator this)

Transform a cursor or cursor future to an iterator

as-list clj

(as-list this)

Transform a cursor or cursor future to a list

reducible clj

(reducible cursor)