Liking cljdoc? Tell your friends :D

qbits.alia.manifold


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

execute-bufferedclj

source

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

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

handle-page-completion-stageclj

(handle-page-completion-stage completion-stage {stream :stream :as opts})
source

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

× close