reactive_mutiny::prelude::advanced

Type Alias UniZeroCopyFullSync

Source 
pub type UniZeroCopyFullSync<InType, const BUFFER_SIZE: usize, const MAX_STREAMS: usize = 1, const INSTRUMENTS: usize = {Instruments::LogsWithMetrics.into()}> = Uni<InType, ChannelUniZeroCopyFullSync<InType, BUFFER_SIZE, MAX_STREAMS>, INSTRUMENTS, OgreUnique<InType, AllocatorFullSyncArray<InType, BUFFER_SIZE>>>;

Aliased Type§

pub struct UniZeroCopyFullSync<InType, const BUFFER_SIZE: usize, const MAX_STREAMS: usize = 1, const INSTRUMENTS: usize = {Instruments::LogsWithMetrics.into()}> {
    pub channel: Arc<FullSync<'static, InType, OgreArrayPoolAllocator<InType, FullSyncMove<u32, BUFFER_SIZE>, BUFFER_SIZE>, BUFFER_SIZE, MAX_STREAMS>>,
    pub stream_executors: Vec<Arc<StreamExecutor<INSTRUMENTS>>>,
    pub finished_executors_count: AtomicU32,
    /* private fields */
}

Fields§

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