Interface IPipeline<TInput, TOutput>

Namespace

Orleans.GpuBridge.BridgeFX

Assembly

Orleans.GpuBridge.BridgeFX.dll

Interface for executable pipeline

public interface IPipeline<TInput, TOutput> where TInput : notnull where TOutput : notnull

Type Parameters

TInput

TOutput

Methods

ProcessAsync(TInput, CancellationToken)

Processes a single item through the pipeline

Task<TOutput> ProcessAsync(TInput input, CancellationToken ct = default)

Parameters

input TInput

ct CancellationToken

Returns

Task<TOutput>

ProcessChannelAsync(ChannelReader<TInput>, ChannelWriter<TOutput>, CancellationToken)

Processes items from a channel

Task ProcessChannelAsync(ChannelReader<TInput> input, ChannelWriter<TOutput> output, CancellationToken ct = default)

Parameters

input ChannelReader<TInput>

output ChannelWriter<TOutput>

ct CancellationToken

Returns

Task

ProcessManyAsync(IAsyncEnumerable<TInput>, CancellationToken)

Processes multiple items through the pipeline

IAsyncEnumerable<TOutput> ProcessManyAsync(IAsyncEnumerable<TInput> inputs, CancellationToken ct = default)

Parameters

inputs IAsyncEnumerable<TInput>

ct CancellationToken

Returns

IAsyncEnumerable<TOutput>