Is there an equivalent

trySendBlocking

to send exceptions down the channel?

close(Throwable)

?

Doesn't that also close the channel? I assumed the mental model of FS2 scala channels, where after an exception trudges along, you can keep receiving messages, if you handle the exception along the way.

Yes, it closes the channel too. If you don't want this behavior, you can't really use an exception (it would crash the collector, so the collection would stop anyway). What you can do instead is materialize the exception using your own type (like a

Result

) and send it normally like other elements

Ah, ok. Tried to use something like https://www.javadoc.io/static/co.fs2/fs2-docs_2.13/3.2.9/fs2/Stream.html#attempt:fs2.Stream[F,Either[Throwable,O]]

nope

Arrow offers an

Either

type, and in Arrow Fx Coroutines it offers similar functionality as Cats-effect and FS2. https://github.com/arrow-kt/arrow

Yeah, probably arrow time

It also exposes a couple of powerful DSLs as alternatives to monadic operators

🤔 I think I'll stuff it into a standard

Result

, until I need to change it. Probably sooner than I'd like.

Result is great if you just need to work over

Throwable

. If you end up using Arrow, and you have any doubts or questions there are many people in#arrow that'd gladly help you out!

Got a "from Haskell to Arrow" somewhere? Or Scala works too 😄

Uhm, not really. It' been on our to-do list for a while, but writing/maintaining docs is hard 😅 There should not be any surprises in Arrow if you already have perquisite knowledge. The goal of Arrow is to offer idiomatic FP in Kotlin with low overhead and a low learning curve.