Remove unneeded constraints on Reducers

Author: louthy

LanguageExt.Streaming/SourceT/Extensions/SourceT.Extensions.cs

@@ -3,9 +3,7 @@
 using System.Diagnostics.Contracts;
 using System.Threading.Channels;
 using LanguageExt.Common;
-using LanguageExt.Pipes;
 using LanguageExt.Traits;
-using static LanguageExt.Prelude;
 
 namespace LanguageExt;
 

LanguageExt.Streaming/SourceT/Extensions/SourceT.Reducers.cs

@@ -7,10 +7,10 @@ namespace LanguageExt;
 
 public static partial class SourceTExtensions
 {
-    /// <param name="ma"></param>
+/// <param name="ma"></param>
     /// <typeparam name="M"></typeparam>
     /// <typeparam name="A"></typeparam>
-    extension<M, A>(K<SourceT<M>, A> ma) where M : MonadIO<M>, Alternative<M>
+    extension<M, A>(K<SourceT<M>, A> ma) where M : MonadIO<M>
     {
         /// <summary>
         /// Force iteration of the stream, yielding a unit `M` structure.
@@ -22,20 +22,6 @@ public static partial class SourceTExtensions
         public K<M, Unit> Iter() =>
             ma.As().FoldReduce(unit, (_, _) => unit);
 
-        /// <summary>
-        /// Force iteration of the stream, yielding the last structure processed
-        /// </summary>
-        [Pure]
-        public K<M, A> Last() =>
-            M.Token.Bind(t =>
-                             ma.As()
-                               .FoldReduce(Option<A>.None, (_, x) => Some(x))
-                               .Bind(ma => ma switch
-                                           {
-                                               { IsSome: true, Case: A value } => M.Pure(value),
-                                               _                               => M.Empty<A>()
-                                           }));
-
         /// <summary>
         /// Collect all the values into a `Seq` while the predicate holds.
         /// </summary>
@@ -66,5 +52,25 @@ public K<M, Seq<A>> CollectUntil(Func<(Seq<A> Items, A Item), bool> predicate) =
         [Pure]
         public K<M, Seq<A>> Collect() =>
             ma.As().FoldReduce<Seq<A>>([], (xs, x) => xs.Add(x));
+    }    
+    
+    /// <param name="ma"></param>
+    /// <typeparam name="M"></typeparam>
+    /// <typeparam name="A"></typeparam>
+    extension<M, A>(K<SourceT<M>, A> ma) where M : MonadIO<M>, Alternative<M>
+    {
+        /// <summary>
+        /// Force iteration of the stream, yielding the last structure processed
+        /// </summary>
+        [Pure]
+        public K<M, A> Last() =>
+            M.Token.Bind(t =>
+                             ma.As()
+                               .FoldReduce(Option<A>.None, (_, x) => Some(x))
+                               .Bind(ma => ma switch
+                                           {
+                                               { IsSome: true, Case: A value } => M.Pure(value),
+                                               _                               => M.Empty<A>()
+                                           }));
     }
 }

LanguageExt.Streaming/SourceT/SourceT.Module.cs

@@ -370,5 +370,5 @@ public static K<M, Seq<A>> collectUntil<M, A>(
     [Pure]
     public static K<M, Seq<A>> collect<M, A>(K<SourceT<M>, A> ma)
         where M : MonadIO<M> =>
-        ma.As().FoldReduce<Seq<A>>([], (xs, x) => xs.Add(x));    
+        ma.As().FoldReduce<Seq<A>>([], (xs, x) => xs.Add(x));
 }