Any pointers as to where I am going wrong will be mighty helpful. Haven't completely understood core.async yet.

I know the problem is in the async part because I have tests for the parts which are easier to test 😂

what is wrong with it?

It just returned an instance of ManyToManyChannel

But OMG I made it work

Turns out I had two calls in the wrong order

I was first filling up the chans with data first and then starting the go-loops. I reversed the order and it seems to work now.

@pawandubey not your main issue, but go-loop and go always return a channel

I figured that out though the docs. But the issue was that the actual work wasn't happening at all