namespace System.Threading.Tasks.Dataflow
{
    public static class DataflowBlock
    {
        public static IAsyncEnumerable<TOutput>! ReceiveAllAsync<TOutput>(this IReceivableSourceBlock<TOutput>! source, CancellationToken cancellationToken = default);
    }
}