hi all, new to core.async, trying to use it to interact with a callback flow but things aren’t working as I would expect

any suggestions?

use put! instead of >!

@exupero: thank you kindly, will try that

You won’t need the go then

ah, ok

reading between the lines, I assume >! is only valid if its a first class subordinate of a go form?

Yep. go re-writes its body to support blocking on >! and <! but doesn’t reach into functions within that body.

lexical scope only

yup yup

hmm, so the problem I am having now is put! is async so I have no flow control

(eventually hit the 1k buffer limit and exception out

is there any method that is compatible with parking the go-based sender that can be invoked from a callback like that?

I could put a promise in the callback for put!, but I feel like I am probably not doing things the intended way, heh

my first inclination was to use >!! but it seems that isnt available within clojurescript (for reasons I can guess)

unless the reason it wouldnt compile was something else and I misinterpreted the error

You could put the go within the anonymous function. That will create a lot of new goroutines, but they should enqueue their puts in order.

Since you can’t block whether lines are read, you might as well use a list.

You could then iterate over the list and put values onto a channel (if you really needed a channel)