Make StreamT experimental

LanguageExt.Core/Async/AsyncEnumerable/AsyncEnumberable.Extensions.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using System;
 using System.Collections.Generic;
 using LanguageExt.Traits;

LanguageExt.Core/DataTypes/Range/Range.cs

@@ -1,4 +1,6 @@
-using LanguageExt.Traits;
+#pragma warning disable LX_StreamT
+
+using LanguageExt.Traits;
 using System;
 using System.Collections.Generic;
 using System.Collections;

LanguageExt.Core/Effects/IO/Free/IOMap.cs

@@ -0,0 +1,27 @@
+/*
+using System;
+using LanguageExt.DSL;
+using LanguageExt.Traits;
+
+namespace LanguageExt;
+
+record IOMap<A, B>(IO<A> Value, Func<A, B> F) : IO<B>
+{
+    public override IO<C> Map<C>(Func<B, C> f) =>
+        new IOMap<A, C>(Value, x => f(F(x)));
+
+    public override IO<C> Bind<C>(Func<B, K<IO, C>> f) =>
+        new IOMap<A, K<IO, C>>(Value, x => f(F(x)).As()).Bind(x => x);
+
+    public override IO<C> ApplyBack<C>(K<IO, Func<B, C>> mf) =>
+        mf switch
+        {
+            IOPure<Func<B, C>> (var f)       => new IOMap<A, C>(Value, x => f(F(x))),
+            IOPureAsync<Func<B, C>> (var tf) => new IOMap<A, IO<C>>(Value, x => IO.pureAsync(tf.Map(f => f(F(x))))).Bind(x => x),  
+            IOFail<Func<B, C>> (var v)       => new IOFail<C>(v),
+            IOBind<Func<B, C>> (var f)       => new IOBind<C>(f.Map(x => x.Apply(this).As())),
+            IOCatch<Func<B, C>> mc           => Value.Bind(a => IO.pure(F(a)).ApplyBack(mc)),
+            _                                => throw new InvalidOperationException()
+        };
+}
+*/

LanguageExt.Core/Effects/IO/IO.Extensions.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using System;
 using System.Diagnostics.Contracts;
 using System.Runtime.CompilerServices;

LanguageExt.Core/Effects/IO/IO.Module.cs

@@ -20,6 +20,15 @@ public partial class IO
     public static IO<A> pure<A>(A value) =>
         IO<A>.Pure(value);
 
+    /// <summary>
+    /// Lift a pure value into an IO computation
+    /// </summary>
+    /// <param name="value">value</param>
+    /// <typeparam name="A">Bound value type</typeparam>
+    /// <returns>IO in a success state.  Always yields the lifted value.</returns>
+    internal static IO<A> pureAsync<A>(Task<A> value) =>
+        new IOPureAsync<A>(value);
+
     /// <summary>
     /// Put the IO into a failure state
     /// </summary>

LanguageExt.Core/Effects/IO/IO.Prelude.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using System;
 using System.Diagnostics.Contracts;
 using System.Runtime.CompilerServices;

LanguageExt.Core/Effects/Prelude.cs

@@ -1,4 +1,6 @@
-using System;
+#pragma warning disable LX_StreamT
+
+using System;
 using LanguageExt.Traits;
 
 namespace LanguageExt;

LanguageExt.Core/Effects/Source/Source.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using System;
 using System.Collections.Concurrent;
 using System.Threading;

LanguageExt.Core/Effects/Source/Sub.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using System;
 using System.Collections.Concurrent;
 using System.Collections.Generic;

LanguageExt.Core/Effects/StreamT/StreamT.Extensions.MapApply.cs

@@ -1,4 +1,6 @@
-using System;
+#pragma warning disable LX_StreamT
+
+using System;
 using LanguageExt.Traits;
 
 namespace LanguageExt;

LanguageExt.Core/Effects/StreamT/StreamT.Extensions.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using System;
 using System.Collections.Generic;
 using System.Linq;

LanguageExt.Core/Effects/StreamT/StreamT.Module.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using LanguageExt.Traits;
 using System.Collections.Generic;
 

LanguageExt.Core/Effects/StreamT/StreamT.Monad.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using System;
 using System.Collections.Generic;
 using LanguageExt.Traits;

LanguageExt.Core/Effects/StreamT/StreamT.Prelude.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using LanguageExt.Traits;
 
 namespace LanguageExt;

LanguageExt.Core/Effects/StreamT/StreamT.Prelude.mapapply.cs

@@ -1,4 +1,6 @@
-using System;
+#pragma warning disable LX_StreamT
+
+using System;
 using LanguageExt.Traits;
 
 namespace LanguageExt;

LanguageExt.Core/Effects/StreamT/StreamT.cs

@@ -1,5 +1,6 @@
 using System;
 using System.Collections.Generic;
+using System.Diagnostics.CodeAnalysis;
 using System.Threading;
 using System.Threading.Tasks;
 using static LanguageExt.Prelude;
@@ -11,6 +12,7 @@ namespace LanguageExt;
 /// <summary>
 /// Lazy sequence monad transformer
 /// </summary>
+[Experimental("LX_StreamT")]
 public record StreamT<M, A>(Func<K<M, MList<A>>>  runListT) :
     K<StreamT<M>, A>,
     Monoid<StreamT<M, A>>

LanguageExt.Core/Immutable Collections/Arr/Arr.cs

@@ -1,4 +1,6 @@
-using System;
+#pragma warning disable LX_StreamT
+
+using System;
 using System.Linq;
 using System.Collections;
 using System.Collections.Generic;

LanguageExt.Core/Immutable Collections/Iterable/Iterable.cs

@@ -1,4 +1,6 @@
-using System;
+#pragma warning disable LX_StreamT
+
+using System;
 using System.Collections;
 using System.Collections.Generic;
 using System.Diagnostics.Contracts;

LanguageExt.Core/Immutable Collections/List/Lst.cs

@@ -1,4 +1,6 @@
-using System;
+#pragma warning disable LX_StreamT
+
+using System;
 using System.Linq;
 using System.Collections;
 using System.Collections.Generic;

LanguageExt.Core/Immutable Collections/Seq/Seq.cs

@@ -1,4 +1,6 @@
-#pragma warning disable CS0693 // Type parameter has the same name as the type parameter from outer type
+#pragma warning disable LX_StreamT
+
+#pragma warning disable CS0693 // Type parameter has the same name as the type parameter from outer type
 
 using System;
 using System.Collections;

LanguageExt.Core/Immutable Collections/Set/Set.cs

@@ -1,4 +1,6 @@
-using System;
+#pragma warning disable LX_StreamT
+
+using System;
 using System.Collections.Generic;
 using System.Collections;
 using static LanguageExt.Prelude;

LanguageExt.Core/Monads/Alternative Monads/Either/Either.cs

@@ -1,4 +1,6 @@
-using System;
+#pragma warning disable LX_StreamT
+
+using System;
 using System.Collections;
 using System.Collections.Generic;
 using static LanguageExt.Prelude;

LanguageExt.Core/Monads/Alternative Monads/EitherT/EitherT.cs

@@ -1,4 +1,6 @@
-using System;
+#pragma warning disable LX_StreamT
+
+using System;
 using System.Diagnostics.Contracts;
 using System.Runtime.CompilerServices;
 using LanguageExt.Traits;

LanguageExt.Core/Monads/Alternative Monads/Fin/Fin.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using System;
 using LanguageExt.Common;
 using LanguageExt.Traits;

LanguageExt.Core/Monads/Alternative Monads/FinT/FinT.cs

@@ -1,4 +1,6 @@
-using System;
+#pragma warning disable LX_StreamT
+
+using System;
 using System.Diagnostics.Contracts;
 using LanguageExt.Common;
 using LanguageExt.Traits;

LanguageExt.Core/Monads/Alternative Monads/Option/Option.cs

@@ -1,4 +1,6 @@
-using System;
+#pragma warning disable LX_StreamT
+
+using System;
 using System.Linq;
 using System.Collections.Generic;
 using static LanguageExt.Prelude;

LanguageExt.Core/Monads/Alternative Monads/OptionT/OptionT.cs

@@ -1,4 +1,6 @@
-using System;
+#pragma warning disable LX_StreamT
+
+using System;
 using System.Diagnostics.Contracts;
 using System.IO;
 using System.Runtime.CompilerServices;

LanguageExt.Core/Monads/Alternative Monads/Validation/Validation.cs

@@ -1,4 +1,6 @@
-using System;
+#pragma warning disable LX_StreamT
+
+using System;
 using System.Collections.Generic;
 using static LanguageExt.Prelude;
 using System.Diagnostics.Contracts;

LanguageExt.Core/Monads/Alternative Monads/ValidationT/ValidationT.cs

@@ -1,4 +1,6 @@
-using System;
+#pragma warning disable LX_StreamT
+
+using System;
 using System.Diagnostics.Contracts;
 using System.Runtime.CompilerServices;
 using LanguageExt.Common;

LanguageExt.Tests/TraitTests/ApplicativeLawTests.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using Xunit;
 namespace LanguageExt.Tests.TraitTests;
 

LanguageExt.Tests/TraitTests/FunctorLawTests.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using Xunit;
 using LanguageExt.Common;
 namespace LanguageExt.Tests.TraitTests;

LanguageExt.Tests/TraitTests/MonadLawsTest.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using Xunit;
 
 namespace LanguageExt.Tests.TraitTests;

Samples/Streams/CountForever.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using LanguageExt;
 using static LanguageExt.Prelude;
 using static Streams.Console;

Samples/Streams/CountForeverAsync.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using LanguageExt;
 using static LanguageExt.Prelude;
 using static Streams.Console;

Samples/Streams/Folding.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using LanguageExt;
 using static Streams.Console;
 using static LanguageExt.Prelude;

Samples/Streams/Grouping.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using LanguageExt;
 using static LanguageExt.Prelude;
 using static Streams.Console;

Samples/Streams/HeadsAndTails.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using LanguageExt;
 using static LanguageExt.Prelude;
 using static Streams.Console;

Samples/Streams/Merging.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using LanguageExt;
 using static Streams.Console;
 using static LanguageExt.Prelude;

Samples/Streams/OptionalItems.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using LanguageExt;
 using static LanguageExt.Prelude;
 

Samples/Streams/SourceStream.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using LanguageExt;
 using LanguageExt.Common;
 using static Streams.Console;

Samples/Streams/SumOfSquares.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using LanguageExt;
 using LanguageExt.Common;
 using LanguageExt.Traits;

Samples/Streams/Zipping.cs

@@ -1,3 +1,5 @@
+#pragma warning disable LX_StreamT
+
 using LanguageExt;
 using static Streams.Console;
 using static LanguageExt.Prelude;