Struct PriorityMerge 

pub struct PriorityMerge<T> { /* private fields */ }

A reactive stream combinator that merges two streams by priority.

When both streams have elements, the left stream takes priority.

Implementations

impl<T: 'static> PriorityMerge<T>

pub fn new(left: LazyStream<T>, right: LazyStream<T>) -> Self

Create a new priority merge of two streams.

pub fn next(&mut self) -> Option<T>

Get the next element, preferring the left stream.

pub fn take_n(&mut self, n: usize) -> Vec<T>

Collect n elements from the merged stream.