Terminate processing (and cancel the upstream publisher) after predicate returns false for the first time. Due to input buffering some elements may have been requested from upstream publishers that will then not be processed downstream of this step. The stream will be completed without producing any elements if predicate is false for the first stream element.

Emits when the predicate is true

Backpressures when downstream backpressures

Completes when predicate returned false or upstream completes

Cancels when predicate returned false or downstream cancels

public static SubFlow<TOut, TMat, TClosed> TakeWhile<TOut, TMat, TClosed>(
	this SubFlow<TOut, TMat, TClosed> flow,
	Predicate<TOut> predicate
)

[<ExtensionAttribute>]
static member TakeWhile : 
        flow : SubFlow<'TOut, 'TMat, 'TClosed> * 
        predicate : Predicate<'TOut> -> SubFlow<'TOut, 'TMat, 'TClosed>