Remove experimental Pipes classes.

Deleted experimental implementations of Channel, Client, Consumer, and related core proxy types. And making them into the main implementation.
louthy · Feb 5, 2025 · 761f3f2 · 761f3f2
1 parent 514bf36
commit 761f3f2
Show file tree

Hide file tree

Showing 64 changed files with 104 additions and 5,897 deletions.
diff --git a/LanguageExt.Pipes/Client/Client.cs b/LanguageExt.Pipes/Client/Client.cs
diff --git a/LanguageExt.Pipes/Client/CoreTypes.cs b/LanguageExt.Pipes/Client/CoreTypes.cs
diff --git a/Samples/PipesExamples/Concurrent/Buffer.cs → LanguageExt.Pipes/Concurrent/Buffer.cs b/Samples/PipesExamples/Concurrent/Buffer.cs → LanguageExt.Pipes/Concurrent/Buffer.cs
@@ -1,4 +1,4 @@
-namespace LanguageExt.Pipes2.Concurrent;
+namespace LanguageExt.Pipes.Concurrent;
 
 /// <summary>
 /// Settings for `Mailbox` channels

diff --git a/...mples/Concurrent/Inbox/Inbox.CoFunctor.cs → ...Pipes/Concurrent/Inbox/Inbox.CoFunctor.cs b/...mples/Concurrent/Inbox/Inbox.CoFunctor.cs → ...Pipes/Concurrent/Inbox/Inbox.CoFunctor.cs
@@ -1,6 +1,7 @@
+using System;
 using LanguageExt.Traits;
 
-namespace LanguageExt.Pipes2.Concurrent;
+namespace LanguageExt.Pipes.Concurrent;
 
 public class Inbox : Decidable<Inbox>
 {

diff --git a/...pesExamples/Concurrent/Inbox/Inbox.DSL.cs → ...geExt.Pipes/Concurrent/Inbox/Inbox.DSL.cs b/...pesExamples/Concurrent/Inbox/Inbox.DSL.cs → ...geExt.Pipes/Concurrent/Inbox/Inbox.DSL.cs
@@ -1,8 +1,9 @@
+using System;
 using System.Threading.Channels;
 using LanguageExt.Common;
 using static LanguageExt.Prelude;
 
-namespace LanguageExt.Pipes2.Concurrent;
+namespace LanguageExt.Pipes.Concurrent;
 
 record InboxWriter<A>(ChannelWriter<A> Writer) : Inbox<A>
 {

diff --git a/...ples/Concurrent/Inbox/Inbox.Extensions.cs → ...ipes/Concurrent/Inbox/Inbox.Extensions.cs b/...ples/Concurrent/Inbox/Inbox.Extensions.cs → ...ipes/Concurrent/Inbox/Inbox.Extensions.cs
@@ -1,6 +1,6 @@
 using LanguageExt.Traits;
 
-namespace LanguageExt.Pipes2.Concurrent;
+namespace LanguageExt.Pipes.Concurrent;
 
 public static class InboxExtensions
 {

diff --git a/...s/PipesExamples/Concurrent/Inbox/Inbox.cs → LanguageExt.Pipes/Concurrent/Inbox/Inbox.cs b/...s/PipesExamples/Concurrent/Inbox/Inbox.cs → LanguageExt.Pipes/Concurrent/Inbox/Inbox.cs
@@ -1,7 +1,8 @@
+using System;
 using LanguageExt.Common;
 using LanguageExt.Traits;
 
-namespace LanguageExt.Pipes2.Concurrent;
+namespace LanguageExt.Pipes.Concurrent;
 
 /// <summary>
 /// Entry point to a channel.  Inboxes receive values and propagate them through the

diff --git a/...ples/Concurrent/Mailbox/Mailbox.Module.cs → ...ipes/Concurrent/Mailbox/Mailbox.Module.cs b/...ples/Concurrent/Mailbox/Mailbox.Module.cs → ...ipes/Concurrent/Mailbox/Mailbox.Module.cs
@@ -1,5 +1,6 @@
+using System;
 using Ch = System.Threading.Channels;
-namespace LanguageExt.Pipes2.Concurrent;
+namespace LanguageExt.Pipes.Concurrent;
 
 public static class Mailbox
 {

diff --git a/...pesExamples/Concurrent/Mailbox/Mailbox.cs → ...geExt.Pipes/Concurrent/Mailbox/Mailbox.cs b/...pesExamples/Concurrent/Mailbox/Mailbox.cs → ...geExt.Pipes/Concurrent/Mailbox/Mailbox.cs
@@ -1,7 +1,8 @@
+using System;
 using LanguageExt.Common;
 using LanguageExt.Traits;
 
-namespace LanguageExt.Pipes2.Concurrent;
+namespace LanguageExt.Pipes.Concurrent;
 
 /// <summary>
 /// Represents a channel.  A channel has:

diff --git a/...sExamples/Concurrent/Outbox/Outbox.DSL.cs → ...Ext.Pipes/Concurrent/Outbox/Outbox.DSL.cs b/...sExamples/Concurrent/Outbox/Outbox.DSL.cs → ...Ext.Pipes/Concurrent/Outbox/Outbox.DSL.cs
@@ -1,7 +1,10 @@
+using System;
+using System.Threading;
 using System.Threading.Channels;
+using System.Threading.Tasks;
 using LanguageExt.Common;
 
-namespace LanguageExt.Pipes2.Concurrent;
+namespace LanguageExt.Pipes.Concurrent;
 
 record OutboxPure<A>(A Value) : Outbox<A>
 {

diff --git a/...es/Concurrent/Outbox/Outbox.Extensions.cs → ...es/Concurrent/Outbox/Outbox.Extensions.cs b/...es/Concurrent/Outbox/Outbox.Extensions.cs → ...es/Concurrent/Outbox/Outbox.Extensions.cs
@@ -1,6 +1,6 @@
 using LanguageExt.Traits;
 
-namespace LanguageExt.Pipes2.Concurrent;
+namespace LanguageExt.Pipes.Concurrent;
 
 public static class OutboxExtensions
 {

diff --git a/...ples/Concurrent/Outbox/Outbox.Internal.cs → ...ipes/Concurrent/Outbox/Outbox.Internal.cs b/...ples/Concurrent/Outbox/Outbox.Internal.cs → ...ipes/Concurrent/Outbox/Outbox.Internal.cs
@@ -1,6 +1,8 @@
+using System.Threading;
+using System.Threading.Tasks;
 using LanguageExt.Common;
 
-namespace LanguageExt.Pipes2.Concurrent;
+namespace LanguageExt.Pipes.Concurrent;
 
 internal class OutboxInternal
 {

diff --git a/LanguageExt.Pipes/Concurrent/Outbox/Outbox.Module.cs b/LanguageExt.Pipes/Concurrent/Outbox/Outbox.Module.cs
@@ -0,0 +1,6 @@
+namespace LanguageExt.Pipes.Concurrent;
+
+public partial class Outbox
+{
+
+}