Liking cljdoc? Tell your friends :D

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
sourceraw docstring

execute-bufferedclj

source

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`
sourceraw docstring

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-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
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`
sourceraw docstring

handle-page-completion-stageclj

(handle-page-completion-stage
  completion-stage
  {chan :chan stop? :qbits.alia.async/stop? :as opts})
source

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

× close