Trait dora_node_api::merged::MergeExternal

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

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

Required Associated Types

type Item

Required Methods

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

Implementors

impl<'a, E> MergeExternal<'a, E> for EventStreamwhere E: 'static,

type Item = MergedEvent<E>

impl<'a, E, F, S> MergeExternal<'a, F> for Swhere S: Stream<Item = MergedEvent<E>> + Send + Unpin + 'a, E: 'a, F: 'a,

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