Interface IDataFlowExecutableSource

Shared methods for sources that can be executed

Namespace: ETLBox.DataFlow
Assembly: ETLBox.dll
Syntax
    public interface IDataFlowExecutableSource

Methods

Execute()

Starts the data flow for all connected components (also for other sources in the network). Waits until all destinations run to completion.

Declaration
    void Execute()

Execute(CancellationToken)

Declaration
    void Execute(CancellationToken cancellationToken)
Parameters
TypeNameDescription
System.Threading.CancellationTokencancellationToken

A cancellation token which can be used to cancel the task of component (and all subsequent components in the flow)

ExecuteAsync()

Starts the data flow asynchronously.

Declaration
    Task ExecuteAsync()
Returns
TypeDescription
System.Threading.Tasks.Task

Returns an awaitable task that completes or faults when the flow ran to completion.

ExecuteAsync(CancellationToken)

Starts the data flow asynchronously.

Declaration
    Task ExecuteAsync(CancellationToken cancellationToken)
Parameters
TypeNameDescription
System.Threading.CancellationTokencancellationToken

A cancellation token which can be used to cancel the task of component (and all subsequent components in the flow)

Returns
TypeDescription
System.Threading.Tasks.Task

Returns an awaitable task that completes or faults when the flow ran to completion.

Post()

Starts the data flow partly synchronously. This method will return when all data was posted into the flow.

Declaration
    void Post()

Post(CancellationToken)

Declaration
    void Post(CancellationToken cancellationToken)
Parameters
TypeNameDescription
System.Threading.CancellationTokencancellationToken

A cancellation token which can be used to cancel the task of component (and all subsequent components in the flow)