Trait MergeExternal 

pub trait MergeExternal<'a, E> {
    type Item;

    // Required method
    fn merge_external(
        self,
        external_events: impl Stream<Item = E> + Unpin + 'a,
    ) -> Box<dyn Stream<Item = Self::Item> + Unpin + 'a>;
}

Allows merging an external event stream into an existing event stream.

Required Associated Types

type Item

The item type yielded from the merged stream.

Required Methods

fn merge_external( self, external_events: impl Stream<Item = E> + Unpin + 'a, ) -> Box<dyn Stream<Item = Self::Item> + Unpin + 'a>

Merge the given stream into an existing event stream.

Returns a new event stream that yields items from both streams. The ordering between the two streams is not guaranteed.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<'a, E> MergeExternal<'a, E> for EventStream

where E: 'static,

type Item = MergedEvent<E>

impl<'a, E, F, S> MergeExternal<'a, F> for S

where S: Stream<Item = MergedEvent<E>> + Unpin + 'a, E: 'a, F: 'a,

type Item = MergedEvent<Either<E, F>>