Interleave is a deterministic merge of the given SourceTOut, TMat with elements of this FlowTIn, TOut, TMat. It first emits segmentSize number of elements from this flow to downstream, then - same amount for other source, then repeat process. After one of upstreams is complete than all the rest elements will be emitted from the second one If it gets error from one of upstreams - stream completes with failure.

Emits when element is available from the currently consumed upstream

Backpressures when downstream backpressures. Signal to current upstream, switch to next upstream when received segmentSize elements

Completes when the FlowTIn, TOut, TMat and given SourceTOut, TMat completes

Cancels when downstream cancels

public static Flow<TIn, T2, TMat> Interleave<TIn, T1, T2, TMat>(
	this Flow<TIn, T1, TMat> flow,
	IGraph<SourceShape<T2>, TMat> other,
	int segmentSize
)
where T1 : T2

[<ExtensionAttribute>]
static member Interleave : 
        flow : Flow<'TIn, 'T1, 'TMat> * 
        other : IGraph<SourceShape<'T2>, 'TMat> * 
        segmentSize : int -> Flow<'TIn, 'T2, 'TMat>  when 'T1 : 'T2

Source(List(1, 2, 3)).Interleave(List(4, 5, 6, 7), 2) // 1, 2, 4, 5, 3, 6, 7