language-ext

The core SourceT<M> has improvements:

• The | operator which takes the left-hand stream and right-hand stream and merges them into a single stream can now handle errors emitted from either stream and propagate it up through the reducer. Your M type must support Fallible<M> for this to work.
• I have rewritten the internals of StreamT.lift(Channel) to use the new Monad.Recur functi...

This question was raised where a StreamT fold was not terminating. The issue was slightly deeper than I initially thought. SourceT took a different approach to terminating a reducer than Source. SourceT used M.Pure as a terminating value whereas Source has a dedicated structure, Reduced, which has a Continue flag, indica...

The support for generalised monad tail-recursion release that I did in the early hours of Christmas Day needed some support functions, as also requested here, so I have added the following functions to the Monad module:

| Function | Behaviour | | ------- | ------- | |...

Fix for:

• SourceT Skip and Take issues: https://github.com/louthy/language-ext/issues/1503
• Difference between the behaviours of FoldWhile and FoldWhileIO: https://github.com/louthy/language-ext/discussions/1527

A simple update to transducer-lifting in SourceT which fixes issues seen with Skip, Take, and Fold*

Quite a big release here. It's not had a huge amount of testing, but thought it would be good to get it out before I disappear for Christmas, in case anyone wants to have a play with the new features.

Monad.Recur

As suggested here and at various times over the years, we could support the same tailRecM pattern as seen in Cats...