Hello Folks,
I need to construct core.async channel with following semantics:
1. When the channel is created, timeout is attached to channel
2. After timeout passes out, channel is closed
3. It's possible to detach timeout from the channel before it passes out
Now i implemented it with something like this:
(defn create-cancel-channel
[channel-to-notify timeout-ms]
(let [cancel-channel (async/chan)
timeout-channel (async/timeout timeout-ms)]
(async/go
(let [[_ c] (async/alts! [cancel-channel timeout-channel])]
(when (= c timeout-channel)
(async/close! cancel-channel)
(async/close! channel-to-notify))))
cancel-channel))
;; transport channel
(def transport-channel (async/chan))
;; cancel-channel
(def cancel-channel (create-cancel-channel transport-channel 2000))
;; to cancel the transport channel timeout, just close the cancel-channel
(async/close! cancel-channel)
But i'm rather unsatisfied with this solution because it seems little bit
clunky and what's worse,
i need to explicitly keep track of those cancel channels.
Obviously core.async pipe would greatly simplify this, but it seems, that
there's no way to disconnect
piped channels. Maybe mult/tap/untap, even if i won't use broadcasting
semantic of those constructs.
Any other ideas ?
--
You received this message because you are subscribed to the Google
Groups "Clojure" group.
To post to this group, send email to clojure@googlegroups.com
Note that posts from new members are moderated - please be patient with your
first post.
To unsubscribe from this group, send email to
clojure+unsubscr...@googlegroups.com
For more options, visit this group at
http://groups.google.com/group/clojure?hl=en
---
You received this message because you are subscribed to the Google Groups
"Clojure" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to clojure+unsubscr...@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.
