Trait reactive_mutiny::types::FullDuplexMultiChannel

pub trait FullDuplexMultiChannel<'a, ItemType: 'a + Debug + Send + Sync, DerivedItemType: 'a + Debug = ItemType>: ChannelCommon<'a, ItemType, DerivedItemType> + ChannelMulti<'a, ItemType, DerivedItemType> + ChannelProducer<'a, ItemType, DerivedItemType> + ChannelConsumer<'a, DerivedItemType> { }

A fully fledged Multi channel, that has both the producer and consumer parts

Implementors

impl<'a, ItemType: 'a + Debug + Send + Sync, OgreAllocatorType: OgreAllocator<ItemType> + 'a + Sync + Send, const BUFFER_SIZE: usize, const MAX_STREAMS: usize> FullDuplexMultiChannel<'a, ItemType, OgreArc<ItemType, OgreAllocatorType>> for reactive_mutiny::multi::channels::ogre_arc::atomic::Atomic<'a, ItemType, OgreAllocatorType, BUFFER_SIZE, MAX_STREAMS>

impl<'a, ItemType: 'a + Debug + Send + Sync, OgreAllocatorType: OgreAllocator<ItemType> + 'a + Sync + Send, const BUFFER_SIZE: usize, const MAX_STREAMS: usize> FullDuplexMultiChannel<'a, ItemType, OgreArc<ItemType, OgreAllocatorType>> for reactive_mutiny::multi::channels::ogre_arc::full_sync::FullSync<'a, ItemType, OgreAllocatorType, BUFFER_SIZE, MAX_STREAMS>

impl<'a, ItemType: 'a + Debug + Send + Sync, const BUFFER_SIZE: usize, const MAX_STREAMS: usize> FullDuplexMultiChannel<'a, ItemType, Arc<ItemType>> for reactive_mutiny::multi::channels::arc::atomic::Atomic<'a, ItemType, BUFFER_SIZE, MAX_STREAMS>

impl<'a, ItemType: 'a + Debug + Send + Sync, const BUFFER_SIZE: usize, const MAX_STREAMS: usize> FullDuplexMultiChannel<'a, ItemType, Arc<ItemType>> for Crossbeam<'a, ItemType, BUFFER_SIZE, MAX_STREAMS>

impl<'a, ItemType: 'a + Debug + Send + Sync, const BUFFER_SIZE: usize, const MAX_STREAMS: usize> FullDuplexMultiChannel<'a, ItemType, Arc<ItemType>> for reactive_mutiny::multi::channels::arc::full_sync::FullSync<'a, ItemType, BUFFER_SIZE, MAX_STREAMS>

impl<'a, ItemType: 'a + Debug + Send + Sync, const MAX_STREAMS: usize> FullDuplexMultiChannel<'a, ItemType, &'static ItemType> for MmapLog<'a, ItemType, MAX_STREAMS>