Channel Extensions

[DJGosnell]

Modifications

• Added the following extensions for common scenarios of Channel usage.
• Added NexusPipeReader.IsComplete property.
• Fixed issue with AdvanceTo not advancing the examined position.

Usage Exmaple

public static async ValueTask WriteAndComplete<T>(
    this INexusDuplexChannel<T> channel,
    IEnumerable<T> enumerableData,
    int chunkSize = 10,
    CancellationToken cancellationToken = default)

public static async ValueTask WriteAndComplete<T>(
    this INexusChannelWriter<T> writer,
    IEnumerable<T> enumerableData,
    int chunkSize = 10,
    CancellationToken cancellationToken = default)

public static async ValueTask<List<T>> ReadUntilComplete<T>(
    this INexusDuplexChannel<T> channel,
    int estimatedSize = 0,
    CancellationToken cancellationToken = default)

public static async ValueTask<List<T>> ReadUntilComplete<T>(
    this INexusChannelReader<T> reader,
    int estimatedSize = 0,
    CancellationToken cancellationToken = default)