| FlowOperations.Intersperse<TIn, TOut, TMat> Method (Flow<TIn, TOut, TMat>, TOut, TOut, TOut) |
Intersperses stream with provided element, similar to how
Join(String,String[] )
injects a separator between a collection's elements.
Additionally can inject start and end marker elements to stream.
In case you want to only prepend or only append an element (yet still use the intercept feature
to inject a separator between elements, you may want to use the following pattern instead of the 3-argument
version of intersperse (See
Concat< TIn, TOut> for semantics details).
Emits when upstream emits (or before with the start element if provided)
Backpressures when downstream backpressures
Completes when upstream completes
Cancels when downstream cancels
Namespace:
Akka.Streams.Dsl
Assembly:
Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.42 (1.2.3.42)
Syntax public static Flow<TIn, TOut, TMat> Intersperse<TIn, TOut, TMat>(
this Flow<TIn, TOut, TMat> flow,
TOut start,
TOut inject,
TOut end
)
[<ExtensionAttribute>]
static member Intersperse :
flow : Flow<'TIn, 'TOut, 'TMat> *
start : 'TOut *
inject : 'TOut *
end : 'TOut -> Flow<'TIn, 'TOut, 'TMat>
Parameters
- flow
- Type: Akka.Streams.Dsl.Flow<TIn, TOut, TMat>
TBD - start
- Type: TOut
TBD - inject
- Type: TOut
TBD - end
- Type: TOut
TBD
Type Parameters
- TIn
- TBD
- TOut
- TBD
- TMat
- TBD
Return Value
Type:
Flow<TIn,
TOut,
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).
Exceptions See Also