| FlowOperations.SplitWhen<TIn, TOut, TMat> Method (Flow<TIn, TOut, TMat>, Func<TOut, Boolean>) |
This operation applies the given predicate to all incoming elements and
emits them to a stream of output streams, always beginning a new one with
the current element if the given predicate returns true for it.
Namespace:
Akka.Streams.Dsl
Assembly:
Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.42 (1.2.3.42)
Syntax public static SubFlow<TOut, TMat, Sink<TIn, TMat>> SplitWhen<TIn, TOut, TMat>(
this Flow<TIn, TOut, TMat> flow,
Func<TOut, bool> predicate
)
[<ExtensionAttribute>]
static member SplitWhen :
flow : Flow<'TIn, 'TOut, 'TMat> *
predicate : Func<'TOut, bool> -> SubFlow<'TOut, 'TMat, Sink<'TIn, 'TMat>>
Parameters
- flow
- Type: Akka.Streams.Dsl.Flow<TIn, TOut, TMat>
TBD - predicate
- Type: System.Func<TOut, Boolean>
TBD
Type Parameters
- TIn
- TBD
- TOut
- TBD
- TMat
- TBD
Return Value
Type:
SubFlow<TOut,
TMat,
Sink<TIn,
TMat>>TBD
Usage Note
In Visual Basic and C#, you can call this method as an instance method on any object of type
Flow<TIn,
TOut,
TMat>. When you use instance method syntax to call this method, omit the first parameter. For more information, see
Extension Methods (Visual Basic) or
Extension Methods (C# Programming Guide).
See Also