Idiomatic way to construct potentially time bound target channel in core.async
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.
Re: Idiomatic way to construct potentially time bound target channel in core.async
If anyone is interested, that's roughly what i'm currently thinking about... (ns async-util.input-pipe (:require [clojure.core.async.impl.protocols :as impl] [clojure.core.async :refer [ > 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.
Re: Idiomatic way to construct potentially time bound target channel in core.async
Ok, so i'm thinking about such one-shot detachable input pipe channels... (ns async-util.input-pipe (:require [clojure.core.async.impl.protocols :as impl] [clojure.core.async :refer [ > 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.
