Is it possible to extend ReceiveChannels into Trav...

# arrow

[Derek Berner]

Is it possible to extend ReceiveChannels into Traversable?

[simon.vergauwen]

Can ReceiveChannels fold?

[simon.vergauwen]

If you want to take a swing at it or help out with some kotlinx integration I'd love to help 👍

[Derek Berner]

I'll give it a shot. Yes, they can fold but it's a suspend fun

[simon.vergauwen]

Could ForReceiveChannel be possible?

[simon.vergauwen]

What is your use-case?

[Derek Berner]

Well, it went away

[Derek Berner]

But basically, I had an asynchronous channel using the Kotlin coroutines library. I wanted to traverse it and perform IO on each element sent on the channel, but also close the channel if an exception was raised.

[Derek Berner]

So, something like... ReceiveChannel<A>.(A -> IO<B>) -> IO<ReceiveChannel<B>>

[Derek Berner]

Ugh, `ReceiveChannel`s are asynchronous is the problem.

[Derek Berner]

ReceiveChannel<A>.(A -> IO<B>) -> IO<ReceiveChannel<B>> makes sense but ReceiveChannel<A>.(A -> List<B>) -> List<ReceiveChannel<B>> does not

[simon.vergauwen]

Because they're eager I am assuming?

[Derek Berner]

Yeah