reactive_messaging::prelude

Type Alias UniMove

Source 
pub type UniMove<InType, const BUFFER_SIZE: usize, const MAX_STREAMS: usize, const INSTRUMENTS: usize = reactive_mutiny::::prelude::prelude::UniMove::{constant#0}> = Uni<InType, FullSync<'static, InType, BUFFER_SIZE, MAX_STREAMS>, INSTRUMENTS>;
Expand description

Default UniBuilder for “moving” data around – good for small payloads (< 1k) whose types don’t require a custom Drop function

Aliased Type§

pub struct UniMove<InType, const BUFFER_SIZE: usize, const MAX_STREAMS: usize, const INSTRUMENTS: usize = reactive_mutiny::::prelude::prelude::UniMove::{constant#0}> {
    pub channel: Arc<FullSync<'static, InType, BUFFER_SIZE, MAX_STREAMS>>,
    pub stream_executors: Vec<Arc<StreamExecutor<INSTRUMENTS>>>,
    pub finished_executors_count: AtomicU32,
    /* private fields */
}

Fields§

§channel: Arc<FullSync<'static, InType, BUFFER_SIZE, MAX_STREAMS>>§stream_executors: Vec<Arc<StreamExecutor<INSTRUMENTS>>>§finished_executors_count: AtomicU32