aleph

lxsameer 2017-10-09T21:31:46.000087Z

I set up a pipeline of streams connecting to each other like A -> B -> C

lxsameer 2017-10-09T21:33:05.000088Z

put! a value to A derefs to true, but can't take the value from B uisng try-take!. It timeouts.

lxsameer 2017-10-09T21:33:36.000379Z

It confirmed that B is downstream of A. and a quick REPL version works

lxsameer 2017-10-09T21:33:48.000446Z

but not in the app. Anyidea how to debug it ?

lxsameer 2017-10-09T21:42:09.000063Z

i can't even put! and then take! from A itself ?

2017-10-09T22:09:49.000362Z

Sounds like you have a type mismatch

2017-10-09T22:10:20.000196Z

Put! Itself needs to return a boolean but also stick an object into the next stream

2017-10-09T22:10:37.000326Z

Well, a deferred boolean, that is

lxsameer 2017-10-09T22:11:03.000173Z

yeah the weird part is the it derefs to true

2017-10-09T22:11:53.000026Z

That's so you can determine whether the connecting function succeeded in the put or not

lxsameer 2017-10-09T22:11:59.000326Z

it's now 13 days which I'm trying to figure this out

2017-10-09T22:12:04.000251Z

The return value of the put! Is not the object itself

lxsameer 2017-10-09T22:12:34.000063Z

I see, I mean by derefing to true it means that it successfully put the value into stream. right ?

2017-10-09T22:14:29.000045Z

Yes

2017-10-09T22:14:36.000101Z

It's a little weird

lxsameer 2017-10-09T22:15:23.000103Z

I even tried to walk the pipeline using downstream function to confirm the connections,