qbits.alia.async
executeclj
(execute session query)(execute session query {chan :chan :as opts})similar to qbits.alia/execute, but executes async and returns a
clojure.core.async/promise-chan with a list of all the records from
all pages of results realised in memory
any errors will be result in the result channel containing just an Exception
For options refer to qbits.alia/execute doc
similar to `qbits.alia/execute`, but executes async and returns a `clojure.core.async/promise-chan` with a list of all the records from all pages of results realised in memory any errors will be result in the result channel containing just an Exception For options refer to `qbits.alia/execute` doc
execute-chanclj
(execute-chan session query)(execute-chan session query {out-chan :chan :as opts})like execute-chan-pages, but returns a clojure.core.async/chan<row>
supports all the args of execute-chan-pages
like `execute-chan-pages`, but returns a `clojure.core.async/chan<row>` supports all the args of `execute-chan-pages`
execute-chan-pagesclj
(execute-chan-pages session query)(execute-chan-pages session
query
{chan :chan page-buffer-size :page-buffer-size :as opts})similar to qbits.alia/execute, but executes async and returns a
clojure.core.async/chan<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:chan- optional - the channel to copy records to, defaults to a newclojure.core.async/chanwith buffer size:page-buffer-size
similar to `qbits.alia/execute`, but executes async and returns a `clojure.core.async/chan<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 - `:chan` - optional - the channel to copy records to, defaults to a new `clojure.core.async/chan` with buffer size `:page-buffer-size`
handle-page-completion-stageclj
(handle-page-completion-stage
completion-stage
{chan :chan stop? :qbits.alia.async/stop? :as opts})cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close