public class ThenForEach<I, O1, O2> : IPipe<I, O2[]>
A IPipe<I, O>
that aggregates the result of the specified pipe.
public async Task<O2[]> Run(I input)
Asynchronously processes the specified input and returns the output.
public class ThenForEach<I, O1, O2> : IPipe<I, O2[]>
A IPipe<I, O>
that aggregates the result of the specified pipe.
public async Task<O2[]> Run(I input)
Asynchronously processes the specified input and returns the output.