Allows a faster upstream to progress independently of a slower subscriber by aggregating elements into batches until the subscriber is ready to accept them.For example a batch step might concatenate ByteString elements up to the allowed max limit if the upstream publisher is faster. This element only rolls up elements if the upstream is faster, but if the downstream is faster it will not duplicate elements. Batching will apply for all elements, even if a single element cost is greater than the total allowed limit. In this case, previous batched elements will be emitted, then the "heavy" element will be emitted (after being applied with the seed function) without batching further elements with it, and then the rest of the incoming elements are batched. Emits when downstream stops backpressuring and there is a batched element available Backpressures when there are max weighted batched elements + 1 pending element and downstream backpressures Completes when upstream completes and there is no batched/pending element waiting Cancels when downstream cancels See also ,

public static Source<TOut2, TMat> BatchWeighted<TOut, TOut2, TMat>(
	this Source<TOut, TMat> flow,
	long max,
	Func<TOut, long> costFunction,
	Func<TOut, TOut2> seed,
	Func<TOut2, TOut, TOut2> aggregate
)

[<ExtensionAttribute>]
static member BatchWeighted : 
        flow : Source<'TOut, 'TMat> * 
        max : int64 * 
        costFunction : Func<'TOut, int64> * 
        seed : Func<'TOut, 'TOut2> * 
        aggregate : Func<'TOut2, 'TOut, 'TOut2> -> Source<'TOut2, 'TMat>