DotNext.Threading by .NET Foundation and Contributors

<PackageReference Include="DotNext.Threading" Version="5.0.2" />

.NET API 168,344 bytes

TaskCompletionPipe

public static class TaskCompletionPipe

Provides various extension methods for TaskCompletionPipe<T> class.

public struct Consumer<T> : IAsyncEnumerable<T>

Represents asynchronous consumer for the pipe.

public static Consumer<T> GetConsumer<T>(this TaskCompletionPipe<Task<T>> pipe)

Gets asynchronous consumer.