Hi all

Question xpost from #clojure:

(require '[clojure.core.async :as async :refer [go-loop chan >! <!! close!]]

(defn tst [out]
  (go-loop [[x & xs] (range 5)]
    (when (seq xs)
      (println "now here:" x)
      (>! out x)
      (recur xs))))

(def out (chan 2000))
(tst out)
(close! out)
(println "value here: " (<!! (async/into [] out)))

(let [out (chan 2000)]
  (tst out)
  (close! out)
  (println "value here: " (<!! (async/into [] out))))

My goal is to have a function that uses channels but returns a value (not a channel);

Hmm when I debug and halt on every step it does return properly

I thinkt here’s a timing issue

Channel closed before program is finished or something

Values are not yet delivered, but I already read them via async/into

Hmm

I see i had to wait before reading

E.g., (<!! (async/timeout 100))

I don't think that's a robust solution because the rate with which you generate the number could change.

Hi. I am stuck with using core.async in AWS Lambda handler in Clojurescript. The Lambda handler invokes the callback function, and returns as lambda function's result. The issue I am having is how to return a value when reading a channel, eg outside of a go block. take! just returns nil, while (go ..) block returns yet another channel.

(defn handlerfunc [event context callback]
  (go 
     (callback nil (clj->js  {:body (str (<! ch))}) ))) 

take! takes a callback