Liking cljdoc? Tell your friends :D
Clojure only.

com.github.ivarref.yoltq.report-queue

get-tx-report-queue-multicast!clj

(get-tx-report-queue-multicast! conn id)
(get-tx-report-queue-multicast! conn id send-end-token?)

Multicast the datomic.api/tx-report-queue to different consumers. A multicaster thread is started on demand per connection. conn and id identifies the consumer. Repeated calls using the same conn and id returns the same queue.

The optional third parameter, send-end-token?, if set to true, instructs the multicaster thread to send :end if the queue is stopped. The default value is false.

A queue may be stopped using stop-multicaster-id!, stop-multicaster! or stop-all-multicasters!.

Returns a java.util.concurrent.BlockingQueue like datomic.api/tx-report-queue.

Multicast the datomic.api/tx-report-queue to different consumers.
A multicaster thread is started on demand per connection. `conn` and `id` identifies the consumer.
Repeated calls using the same `conn` and `id` returns the same queue.

The optional third parameter, `send-end-token?`, if set to `true`, instructs the multicaster thread
to send `:end` if the queue is stopped. The default value is `false`.

A queue may be stopped using `stop-multicaster-id!`, `stop-multicaster!` or `stop-all-multicasters!`.

Returns a `java.util.concurrent.BlockingQueue` like `datomic.api/tx-report-queue`.
sourceraw docstring

process-poll-result!clj

(process-poll-result! cfg id-ident poll-result consumer)
source

report-queue-listenerclj

(report-queue-listener running? ready? pool config-atom)
source

stop-all-multicasters!clj

(stop-all-multicasters!)
source

stop-multicast-consumer-id!clj

(stop-multicast-consumer-id! conn id)
source

stop-multicaster!clj

(stop-multicaster! conn)
source

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

Keyboard shortcutsReport a problemcljdoc on GitHub
× close