Transform this stream by applying the given function collector to each of the elements on which the function is defined (read: returns not null) as they pass through this processing step. Non-matching elements are filtered out.

Emits when the provided function collector is defined for the element

Backpressures when the function collector is defined for the element and downstream backpressures

Completes when upstream completes

Cancels when downstream cancels

public static Source<TOut2, TMat> Collect<TOut1, TOut2, TMat>(
	this Source<TOut1, TMat> flow,
	Func<TOut1, TOut2> collector
)

[<ExtensionAttribute>]
static member Collect : 
        flow : Source<'TOut1, 'TMat> * 
        collector : Func<'TOut1, 'TOut2> -> Source<'TOut2, 'TMat>