ToAsyncEnumerable

Convert ChannelReader<T> to IAsyncEnumerable<T>.

Declaration (has overloads)

public static IAsyncEnumerable<T> ToAsyncEnumerable<T>(this ChannelReader<T> reader,
                                                            ChannelParallelOptions options)

Example

using Amphisbaena;
using Amphisbaena.Linq;

...

int[] data = new int[] {1, 2, 3};

var q = data
  .ToChannelReader()
  .Select(x => x + 10)
  .ToAsyncEnumerable();  

await foreach(int item in q.ConfigureAwait(false))
  Console.WriteLine(item);