Type Alias reactive_mutiny::prelude::advanced::MultiAtomicOgreArc

pub type MultiAtomicOgreArc<ItemType, const BUFFER_SIZE: usize, const MAX_STREAMS: usize, const INSTRUMENTS: usize = {Instruments::LogsWithMetrics.into()}> = Multi<ItemType, ChannelMultiOgreArcAtomic<ItemType, BUFFER_SIZE, MAX_STREAMS>, INSTRUMENTS, OgreArc<ItemType, AllocatorAtomicArray<ItemType, BUFFER_SIZE>>>;

Aliased Type

struct MultiAtomicOgreArc<ItemType, const BUFFER_SIZE: usize, const MAX_STREAMS: usize, const INSTRUMENTS: usize = {Instruments::LogsWithMetrics.into()}> {
    pub multi_name: String,
    pub channel: Arc<Atomic<'static, ItemType, OgreArrayPoolAllocator<ItemType, AtomicMove<u32, BUFFER_SIZE>, BUFFER_SIZE>, BUFFER_SIZE, MAX_STREAMS>>,
    pub executor_infos: RwLock<IndexMap<String, ExecutorInfo>>,
    /* private fields */
}

Fields

multi_name: String

channel: Arc<Atomic<'static, ItemType, OgreArrayPoolAllocator<ItemType, AtomicMove<u32, BUFFER_SIZE>, BUFFER_SIZE>, BUFFER_SIZE, MAX_STREAMS>>

executor_infos: RwLock<IndexMap<String, ExecutorInfo>>