I set up a pipeline of streams connecting to each other like A -> B -> C
put!
a value to A derefs to true, but can't take the value from B uisng try-take!
. It timeouts.
It confirmed that B is downstream of A. and a quick REPL version works
but not in the app. Anyidea how to debug it ?
i can't even put! and then take! from A itself ?
Sounds like you have a type mismatch
Put! Itself needs to return a boolean but also stick an object into the next stream
Well, a deferred boolean, that is
yeah the weird part is the it derefs to true
That's so you can determine whether the connecting function succeeded in the put or not
it's now 13 days which I'm trying to figure this out
The return value of the put! Is not the object itself
I see, I mean by derefing to true it means that it successfully put the value into stream. right ?
Yes
It's a little weird
I even tried to walk the pipeline using downstream
function to confirm the connections,