An agent which executes a Func<TState, T, CancellationToken, Task<TState>> for each message from a ConcurrentQueue<T>, accumulating an internal state. - View it on GitHub