INNER CODE UNIT · C#

derivedSink

Nonanti/PipeFlow · samples/PipeFlow.Sandbox/Program.cs:537

    IPipelineSink<DataRow> derivedSink = baseSink; // compiles only if in T works
    return derivedSink is not null;
});

await runner.RunAsync("6.6 sink can iterate empty source without failure", async () =>
{
    var sink = new CollectingSink();
    await sink.WriteAsync(AsyncEmpty());
    return sink.Received.Count == 0;

    static async IAsyncEnumerable<DataRow> AsyncEmpty()
    {
        await Task.CompletedTask;
        yield break;
    }
});

// ---------------------------------------------------------------

View source record →