Class StateWriterExtensions
Extension methods for the IStateWriter interface.
Inheritance
Namespace: Reaqtor.QueryEngine
Assembly: Reaqtor.QueryEngine.Interfaces.dll
Syntax
public static class StateWriterExtensions : ObjectMethods
CommitAsync(IStateWriter)
Commits the transaction.
Declaration
public static Task CommitAsync(this IStateWriter writer)Parameters
| Type | Name | Description |
|---|---|---|
| IStateWriter | writer | State writer to commit the transaction on. |
Returns
| Type | Description |
|---|---|
| System.Threading.Tasks.Task | Task to observe the eventual completion of the commit operation. |
Remarks
Prior to calling this method, all item writer streams should be disposed.
CommitAsync(IStateWriter, IProgress<Int32>)
Commits the transaction.
Declaration
public static Task CommitAsync(this IStateWriter writer, IProgress<int> progress)Parameters
| Type | Name | Description |
|---|---|---|
| IStateWriter | writer | State writer to commit the transaction on. |
| System.IProgress<System.Int32> | progress | (Optional) Progress indicator reporting progress percentages. |
Returns
| Type | Description |
|---|---|
| System.Threading.Tasks.Task | Task to observe the eventual completion of the commit operation. |
Remarks
Prior to calling this method, all item writer streams should be disposed.
CommitAsync(IStateWriter, CancellationToken)
Commits the transaction.
Declaration
public static Task CommitAsync(this IStateWriter writer, CancellationToken token)Parameters
| Type | Name | Description |
|---|---|---|
| IStateWriter | writer | State writer to commit the transaction on. |
| System.Threading.CancellationToken | token | Cancellation token to observe cancellation requests. |
Returns
| Type | Description |
|---|---|
| System.Threading.Tasks.Task | Task to observe the eventual completion of the commit operation. |
Remarks
Prior to calling this method, all item writer streams should be disposed.