A generation's duplex core.async endpoint and resumable wire queues. Port commits establish transfer; the application's lifetime task establishes processing and cleanup completion. Transport loss cancels neither.
A generation's duplex core.async endpoint and resumable wire queues. Port commits establish transfer; the application's lifetime task establishes processing and cleanup completion. Transport loss cancels neither.
(flush! {:keys [!state outgoing opts]})Waits for receipt of committed puts; pending puts have not been admitted.
Waits for receipt of committed puts; pending puts have not been admitted.
(retire! {:keys [!state incoming outgoing drained ended! notify!] :as gen}
reason)Close both admissions. Keep incoming data; consume pending puts into a sink. Completion still belongs to the application task, independently of closure.
Close both admissions. Keep incoming data; consume pending puts into a sink. Completion still belongs to the application task, independently of closure.
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |