Tortuga.Chain Namespace
Tortuga.Chain.Access Namespace
Tortuga.Chain.Aggregates Namespace
Tortuga.Chain.Appenders Namespace
Tortuga.Chain.AuditRules Namespace
Tortuga.Chain.CommandBuilders Namespace
Tortuga.Chain.Core Namespace
Tortuga.Chain.DataSources Namespace
Tortuga.Chain.Materializers Namespace
Tortuga.Chain.Metadata Namespace
Tortuga.Chain.MySql Namespace
Tortuga.Chain.MySql.CommandBuilders Namespace
Tortuga.Chain.PostgreSql Namespace
Tortuga.Chain.PostgreSql.CommandBuilders Namespace
Tortuga.Chain.SQLite Namespace
Tortuga.Chain.SqlServer Namespace
Tortuga.Chain.SqlServer.CommandBuilders Namespace

CommandExecutionToken<(Of <(<'TCommand, TParameter>)>)>..::..ExecuteStreamAsync Method

Executes the specified implementation asynchronously.

Namespace:  Tortuga.Chain.Core
Assembly:  Tortuga.Chain.Core (in Tortuga.Chain.Core.dll)

Syntax

public Task<StreamingCommandCompletionToken> ExecuteStreamAsync(
	StreamingCommandImplementationAsync<TCommand> implementation,
	CancellationToken cancellationToken,
	Nullable<Object> state
)
Public Function ExecuteStreamAsync ( _
	implementation As StreamingCommandImplementationAsync(Of TCommand), _
	cancellationToken As CancellationToken, _
	state As Nullable(Of Object) _
) As Task(Of StreamingCommandCompletionToken)
public:
Task<StreamingCommandCompletionToken^>^ ExecuteStreamAsync(
	StreamingCommandImplementationAsync<TCommand>^ implementation, 
	CancellationToken^ cancellationToken, 
	Nullable<Object^> state
)

Parameters

implementation
Type: Tortuga.Chain.Core..::..StreamingCommandImplementationAsync<(Of <(<'TCommand>)>)>
The implementation.
cancellationToken
Type: CancellationToken
The cancellation token.
state
Type: Nullable<(Of <(<'Object>)>)>
The state.

Return Value

The caller is expected to use the StreamingCommandCompletionToken to close any lingering connections and fire appropriate events.

See Also

CommandExecutionToken<(Of <(<'TCommand, TParameter>)>)> Class
Tortuga.Chain.Core Namespace