dora_node_api::merged

Trait MergeExternalSend

Source
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§

Required Methods§

Source

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

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§

Source§

impl<'a, E> MergeExternalSend<'a, E> for EventStream
where E: 'static,

Source§

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