Trait MergeExternalSend 

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

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

Allows merging a sendable external event stream into an existing (sendable) event stream.

By implementing Send, the streams can be sent to different threads.

Required Associated Types

type Item

The item type yielded from the merged stream.

Required Methods

fn merge_external_send( self, external_events: impl Stream<Item = E> + Unpin + Send + Sync + 'a, ) -> Box<dyn Stream<Item = Self::Item> + Unpin + Send + Sync + '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> MergeExternalSend<'a, E> for EventStream

where E: 'static,

type Item = MergedEvent<E>

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

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

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