Fork me on GitHub
#aleph
<
2017-10-09
>
lxsameer21:10:46

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

lxsameer21:10:05

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

lxsameer21:10:36

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

lxsameer21:10:48

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

lxsameer21:10:09

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

ehashman22:10:49

Sounds like you have a type mismatch

ehashman22:10:20

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

ehashman22:10:37

Well, a deferred boolean, that is

lxsameer22:10:03

yeah the weird part is the it derefs to true

ehashman22:10:53

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

lxsameer22:10:59

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

ehashman22:10:04

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

lxsameer22:10:34

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

ehashman22:10:36

It's a little weird

lxsameer22:10:23

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