qbits.alia.async
executeclj
(execute session query)(execute session query {chan :chan :as opts})similar to qbits.alia/execute, but returns a
clojure.core.async/promise-chan with just the first page of
results. Exceptions are sent to the channel as a
value, it's your responsability to handle these how you deem
appropriate.
For options refer to qbits.alia/execute doc
similar to `qbits.alia/execute`, but returns a `clojure.core.async/promise-chan` with just the first page of results. Exceptions are sent to the channel as a value, it's your responsability to handle these how you deem appropriate. 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