Liking cljdoc? Tell your friends :D
Clojure only.
qbits.alia.manifold
concat-seq-sclj
(concat-seq-s stream-s)concat a stream of seqs onto a stream of plain values
concat a stream of seqs onto a stream of plain values
executeclj
(execute session query)(execute session query {:as opts})similar to qbits.alia/execute, but executes async
- returns a
Deferred<records>with all the records from all pages of results realised in memory
any errors will error the result Deferred
similar to `qbits.alia/execute`, but executes async - returns a `Deferred<records>` with all the records from all pages of results realised in memory any errors will error the result Deferred
execute-streamclj
(execute-stream session query)(execute-stream session query {:as opts})like execute-stream-pages, but returns a Stream<row>
supports all the args of execute-stream-pages
like `execute-stream-pages`, but returns a `Stream<row>` supports all the args of `execute-stream-pages`
execute-stream-pagesclj
(execute-stream-pages session query)(execute-stream-pages
session
query
{stream :stream page-buffer-size :page-buffer-size :as opts})similar to qbits.alia/execute, but executes async and returns a
Stream<AliaAsyncResultSetPage>
the :current-page of each AliaAsyncResultSetPage is built by
applying :result-set-fn (default clojure.core/seq) to an
Iterable + IReduceInit supporting version of the AsyncResultSet
supports all the args of qbits.alia/execute and:
:page-buffer-sizedetermines the number of pages to buffer ahead, defaults to 1:stream- optional - the stream to copy records to, defaults to a new stream with buffer size:page-buffer-size
similar to `qbits.alia/execute`, but executes async and returns a `Stream<AliaAsyncResultSetPage>` the `:current-page` of each `AliaAsyncResultSetPage` is built by applying `:result-set-fn` (default `clojure.core/seq`) to an `Iterable` + `IReduceInit` supporting version of the `AsyncResultSet` supports all the args of `qbits.alia/execute` and: - `:page-buffer-size` determines the number of pages to buffer ahead, defaults to 1 - `:stream` - optional - the stream to copy records to, defaults to a new stream with buffer size `:page-buffer-size`
handle-page-completion-stageclj
(handle-page-completion-stage completion-stage {stream :stream :as opts})cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close