Trait dora_node_api::merged::MergeExternalSend

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

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

Required Associated Types

type Item

Required Methods

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

Implementors

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

type Item = MergedEvent<E>

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

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