src/process.tests/PipingTests.cs

@@ -2,8 +2,6 @@
 // SPDX-License-Identifier: EUPL-1.2
 
 using System.Text;
-using System.IO.Pipelines;
-using System.Buffers;
 
 using Geekeey.Process.Buffered;
 
@@ -66,23 +64,6 @@ internal sealed class PipingTests
 		await Assert.That(result.StandardOutput.Trim()).IsEqualTo("Hello World!");
 	}
 
-	[Test]
-	public async Task I_can_execute_a_command_and_pipe_the_stdin_from_a_pipe_reader()
-	{
-		var pipe = new Pipe();
-		await pipe.Writer.WriteAsync("Hello World!"u8.ToArray());
-		await pipe.Writer.CompleteAsync();
-
-		var cmd = PipeSource.FromPipeReader(pipe.Reader) |
-				  new Command(Testing.Fixture.Program.FilePath)
-					  .WithArguments("echo-stdin");
-
-		var result = await cmd.ExecuteBufferedAsync();
-
-		await Assert.That(result.StandardOutput.Trim()).IsEqualTo("Hello World!");
-		await pipe.Reader.CompleteAsync();
-	}
-
 	[Test]
 	public async Task I_can_execute_a_command_and_pipe_the_stdin_from_a_stream_with_a_custom_buffer_size()
 	{
@@ -589,50 +570,6 @@ internal sealed class PipingTests
 		}
 	}
 
-	[Test]
-	public async Task I_can_execute_a_command_and_pipe_the_stdout_to_a_pipe_writer()
-	{
-		// Arrange
-		var pipe = new Pipe();
-		var cmd = new Command(Testing.Fixture.Program.FilePath)
-				  .WithArguments(["generate", "blob", "--length", "100000"]) |
-			  PipeTarget.ToPipeWriter(pipe.Writer);
-
-		// Act
-		using var output = new MemoryStream();
-		var executionTask = cmd.ExecuteAsync();
-		while (true)
-		{
-			var result = await pipe.Reader.ReadAsync();
-			foreach (var segment in result.Buffer)
-			{
-				await output.WriteAsync(segment);
-			}
-			pipe.Reader.AdvanceTo(result.Buffer.End);
-			if (result.IsCompleted)
-			{
-				break;
-			}
-		}
-		await executionTask;
-		await pipe.Reader.CompleteAsync();
-
-		await Assert.That(output.Length).IsEqualTo(100_000);
-	}
-
-	[Test]
-	public async Task I_can_execute_a_command_and_pipe_the_stdout_to_a_buffer_writer()
-	{
-		var output = new ArrayBufferWriter<byte>();
-		var cmd = new Command(Testing.Fixture.Program.FilePath)
-				  .WithArguments(["generate", "blob", "--length", "100000"]) |
-			  PipeTarget.ToBufferWriter(output);
-
-		await cmd.ExecuteAsync();
-
-		await Assert.That(output.WrittenCount).IsEqualTo(100_000);
-	}
-
 	[Test]
 	public async Task I_can_execute_a_command_and_pipe_the_stdout_into_multiple_hierarchical_targets()
 	{

src/process/PipeSource.cs

@@ -2,7 +2,6 @@
 // SPDX-License-Identifier: EUPL-1.2
 
 using System.Text;
-using System.IO.Pipelines;
 
 namespace Geekeey.Process;
 
@@ -76,14 +75,6 @@ public abstract partial class PipeSource
 		return Create((target, token) => stream.CopyToAsync(target, bufferSize, token));
 	}
 
-	/// <summary>
-	/// Creates a pipe source that reads from the specified pipe reader.
-	/// </summary>
-	public static PipeSource FromPipeReader(PipeReader reader)
-	{
-		return Create((destination, cancellationToken) => reader.CopyToAsync(destination, cancellationToken));
-	}
-
 	/// <summary>
 	/// Creates a pipe source that reads from the specified file.
 	/// </summary>

src/process/PipeTarget.cs

@@ -2,7 +2,6 @@
 // SPDX-License-Identifier: EUPL-1.2
 
 using System.Buffers;
-using System.IO.Pipelines;
 using System.Text;
 
 namespace Geekeey.Process;
@@ -167,57 +166,6 @@ public partial class PipeTarget
 			await origin.CopyToAsync(stream, bufferSize, cancellationToken));
 	}
 
-	/// <summary>
-	/// Creates a pipe target that writes to the specified pipe writer.
-	/// </summary>
-	public static PipeTarget ToPipeWriter(PipeWriter writer, bool leaveOpen = false)
-	{
-		return Create(async (origin, cancellationToken) =>
-		{
-			var exception = default(Exception);
-			try
-			{
-				await origin.CopyToAsync(writer, cancellationToken);
-				if (!leaveOpen)
-				{
-					await writer.CompleteAsync();
-				}
-			}
-			catch (Exception caught)
-			{
-				exception = caught;
-				throw;
-			}
-			finally
-			{
-				await writer.CompleteAsync(exception);
-			}
-		});
-	}
-
-	/// <summary>
-	/// Creates a pipe target that writes to the specified buffer writer.
-	/// </summary>
-	public static PipeTarget ToBufferWriter(IBufferWriter<byte> writer)
-	{
-		return Create(async (origin, cancellationToken) =>
-		{
-			using var buffer = MemoryPool<byte>.Shared.Rent(MemoryBufferStream.DefaultBufferSize);
-
-			while (true)
-			{
-				var read = await origin.ReadAsync(buffer.Memory, cancellationToken);
-				if (read <= 0)
-				{
-					break;
-				}
-
-				buffer.Memory[..read].Span.CopyTo(writer.GetSpan(read));
-				writer.Advance(read);
-			}
-		});
-	}
-
 	/// <summary>
 	/// Creates a pipe target that writes to the specified file.
 	/// </summary>