Added ToLazy to LazyValue

Author: MorleyDev

src/MorleyDev.Reactive.Monad/Extensions/IOExtensions.cs

@@ -1,6 +1,7 @@
 using System.Collections.Generic;
 using System.Reactive.Linq;
 using MorleyDev.Reactive.Monad.Extensions;
+using System;
 
 namespace MorleyDev.Reactive.Monad.Extensions
 {
@@ -13,7 +14,7 @@ public static class IOExtensionsNestedEnumerable
 		/// <typeparam name="U"></typeparam>
 		/// <param name="self"></param>
 		/// <returns></returns>
-		public static ManyIO<T> Merge<T, U>(this IO<U> self) where U : IEnumerable<T> => self.Select(s => s.ToObservable()).Merge().ToManyIO();
+		public static ManyIO<T> Merge<T>(this IO<IEnumerable<T>> self) => self.Select(s => s.ToObservable()).Merge().ToManyIO();
 
 		/// <summary>
 		/// Merge an IO of an Enumerable into a ManyIO
@@ -22,20 +23,19 @@ public static class IOExtensionsNestedEnumerable
 		/// <typeparam name="U"></typeparam>
 		/// <param name="self"></param>
 		/// <returns></returns>
-		public static ManyIO<T> Concat<T, U>(this IO<U> self) where U : IEnumerable<T> => self.Select(s => s.ToObservable()).Concat().ToManyIO();
+		public static ManyIO<T> Concat<T>(this IO<IEnumerable<T>> self) => self.Select(s => s.ToObservable()).Concat().ToManyIO();
 	}
 
 	public static class IOExtensionsNestedObservable
 	{
-
 		/// <summary>
 		/// Merge an IO of an Enumerable into a ManyIO
 		/// </summary>
 		/// <typeparam name="T"></typeparam>
 		/// <typeparam name="U"></typeparam>
 		/// <param name="self"></param>
 		/// <returns></returns>
-		public static ManyIO<T> Merge<T, U>(this IO<U> self) where U : IObservable<T> => self.SelectMany(s => s).ToManyIO();
+		public static ManyIO<T> Merge<T>(this IO<IObservable<T>> self) => self.SelectMany(s => s).ToManyIO();
 
 		/// <summary>
 		/// Merge an IO of an Enumerable into a ManyIO
@@ -44,6 +44,6 @@ public static class IOExtensionsNestedObservable
 		/// <typeparam name="U"></typeparam>
 		/// <param name="self"></param>
 		/// <returns></returns>
-		public static ManyIO<T> Concat<T, U>(this IO<U> self) where U : IObservable<T> => self.Select(s => (IObservable<T>)s).Concat().ToManyIO();
+		public static ManyIO<T> Concat<T>(this IO<IObservable<T>> self) => self.Select(s => (IObservable<T>)s).Concat().ToManyIO();
 	}
 }

src/MorleyDev.Reactive.Monad/LazyValue.cs

@@ -30,6 +30,8 @@ public IEnumerator<T> GetEnumerator()
 			yield return _value();
 		}
 
+		public Lazy<T> ToLazy() => new Lazy<T>(_value);
+
 		IEnumerator IEnumerable.GetEnumerator() => GetEnumerator();
 	}
 }

test/MorleyDev.Reactive.Monad.SampleTests/IOTests.cs

@@ -1,5 +1,6 @@
 using FluentAssertions;
 using MorleyDev.Reactive.Monad.Extensions;
+using System.Collections.Generic;
 using System.Linq;
 using System.Reactive.Linq;
 using System.Threading.Tasks;
@@ -17,6 +18,8 @@ public async Task Basic()
 			(await IO.Run(() => 10).RunUnsafeIO()).Should().Be(10);
 			(await IO.From(() => 10).Select(m => m * 10)).Should().Be(100);
 			(await Observable.Return(10).ToIO()).Should().Be(10);
+
+			(await IO.From(() => (IEnumerable<int>)new[] { 10 }).Merge()).Should().Be(10);
 		}
 	}
 }