A SinkTIn, TMat that will invoke the given aggregate function for every received element, giving it its previous output (or the given zero value) and the element as input. The returned Task will be completed with value of the final function evaluation when the input stream ends, or completed with the streams exception if there is a failure signaled in the stream.

public static Sink<TIn, Task<TOut>> Aggregate<TIn, TOut>(
	TOut zero,
	Func<TOut, TIn, TOut> aggregate
)

static member Aggregate : 
        zero : 'TOut * 
        aggregate : Func<'TOut, 'TIn, 'TOut> -> Sink<'TIn, Task<'TOut>>