Similar to AggregateTOut1, TOut2, TMat(SourceTOut1, TMat, TOut2, FuncTOut2, TOut1, TOut2) but is not a terminal operation, emits its current value which starts at zero and then applies the current and next value to the given function scan, emitting the next current value. If the function scan throws an exception and the supervision decision is Restart current value starts at zero again the stream will continue.

Emits when the function scanning the element returns a new element

Backpressures when downstream backpressures

Completes when upstream completes

Cancels when downstream cancels

public static Source<TOut2, TMat> Scan<TOut1, TOut2, TMat>(
	this Source<TOut1, TMat> flow,
	TOut2 zero,
	Func<TOut2, TOut1, TOut2> scan
)

[<ExtensionAttribute>]
static member Scan : 
        flow : Source<'TOut1, 'TMat> * 
        zero : 'TOut2 * 
        scan : Func<'TOut2, 'TOut1, 'TOut2> -> Source<'TOut2, 'TMat>