Hi all, I've been using the 'pipeline' function in core.async and the docstring says that the 'from' channel won't be consumed anymore after the 'to' channel is closed (since you probably don't care anymore). In reality, I'm finding that my 'from' channel is still being taken from and the pipeline transducer continues to execute long after I've closed the 'to' channel. Am I misunderstanding the stated behavior or is this a bug? I'm using the latest version (0.4.474). If someone can confirm this is an issue I'm happy to create a jira ticket and attempt a patch.
Minimal example here: https://gist.github.com/RutledgePaulV/6ddb7b29578de4442cd8d946885c38a8 Thanks, Paul -- 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/d/optout.
