src/Projac.Sql/AsyncSqlProjector.cs
/// <summary>
/// Projects the specified messages asynchronously.
/// </summary>
/// <param name="messages">The messages to project.</param>
/// <param name="cancellationToken">The cancellation token.</param>
/// <returns>
///     A <see cref="Task" /> that will return the number of <see cref="SqlNonQueryCommand">commands</see>
///     executed.
/// </returns>
/// <exception cref="System.ArgumentNullException">Thrown when <paramref name="messages"/> are <c>null</c>.</exception>
Projects the specified messages asynchronously.
Projects the specified messages asynchronously .
public Task<int> ProjectAsync(IEnumerable<object> messages, CancellationToken cancellationToken)
        {
            if (messages == null) throw new ArgumentNullException("messages");
            return _executor.
                ExecuteNonQueryAsync(
                    from message in messages
                    from handler in _resolver(message)
                    from statement in handler.Handler(message)
                    select statement,
                    cancellationToken);
        }
public Task < int > ProjectAsync ( IEnumerable < object > messages , CancellationToken cancellationToken ) { if ( messages == null ) throw new ArgumentNullException ( " " ) ; return _executor . ExecuteNonQueryAsync ( from message in messages from handler in _resolver ( message ) from statement in handler . Handler ( message ) select statement , cancellationToken ) ; }
Projects the specified messages asynchronously.
Projects the specified messages asynchronously .
A  that will return the number of commands
A that will return the number of commands
Thrown when  are null
Thrown when are null
messages
IEnumerable<object>
The messages to project.
The messages to project .
cancellationToken
CancellationToken
The cancellation token.
The cancellation token .