diff options
| author | ire <refsdal.ivar@gmail.com> | 2025-05-21 13:59:55 +0200 |
|---|---|---|
| committer | ire <refsdal.ivar@gmail.com> | 2025-05-21 13:59:55 +0200 |
| commit | 22ca1bb29111f9a0246c54e7f81806794198c25f (patch) | |
| tree | 1b1f8e47222f6bd0da07c038095ce0faeffa691a | |
| parent | Update .gitignore (diff) | |
| download | fiinha-22ca1bb29111f9a0246c54e7f81806794198c25f.tar.gz fiinha-22ca1bb29111f9a0246c54e7f81806794198c25f.tar.xz | |
Doc #7
| -rw-r--r-- | README.md | 3 | ||||
| -rw-r--r-- | src/com/github/ivarref/yoltq.clj | 3 |
2 files changed, 5 insertions, 1 deletions
@@ -471,6 +471,9 @@ Added multicast support for `datomic.api/tx-report-queue`: (println "Processing q-item" q-item) (recur)))))) +; The default value for `send-end-token?` is `false`, i.e. the behaviour will be +; identical to that of datomic.api/tx-report-queue. + @(d/transact conn [{:db/doc "new-data"}]) ; Stop the queue: diff --git a/src/com/github/ivarref/yoltq.clj b/src/com/github/ivarref/yoltq.clj index 45f2051..0f63e25 100644 --- a/src/com/github/ivarref/yoltq.clj +++ b/src/com/github/ivarref/yoltq.clj @@ -390,7 +390,8 @@ 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`. + to send `:end` if the queue is stopped. + The default value for `send-end-token?` is `false`. A queue may be stopped using `stop-multicaster-id!`, `stop-multicaster!` or `stop-all-multicasters!`. |