Trait reactive_mutiny::types::FullDuplexMultiChannel

pub trait FullDuplexMultiChannel:
    ChannelCommon<Self::ItemType, Self::DerivedItemType>
    + ChannelMulti<'static, Self::ItemType, Self::DerivedItemType>
    + ChannelProducer<'static, Self::ItemType, Self::DerivedItemType>
    + ChannelConsumer<'static, Self::DerivedItemType> {
    type ItemType: 'static + Debug + Send + Sync;
    type DerivedItemType: 'static + Debug + Send + Sync;

    const MAX_STREAMS: usize;
    const BUFFER_SIZE: usize;
}

A fully fledged Multi channel, that has both the producer and consumer parts Also, laverages generic programming by allowing simpler generic parameters:

    struct MyGenericStruct<T: FullDuplexUniChannel> { the_channel: T }
    let the_channel = uni::channels::xxx<Lots,And,Lots<Of,Generic,Arguments>>::new();
    let my_struct = MyGenericStruct { the_channel };
    // see more at `tests/use_cases.rs`

Required Associated Constants

const MAX_STREAMS: usize

const BUFFER_SIZE: usize

Required Associated Types

type ItemType: 'static + Debug + Send + Sync

type DerivedItemType: 'static + Debug + Send + Sync

Object Safety

This trait is not object safe.

Implementors

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

const MAX_STREAMS: usize = MAX_STREAMS

const BUFFER_SIZE: usize = BUFFER_SIZE

type ItemType = ItemType

type DerivedItemType = Arc<ItemType>

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

const MAX_STREAMS: usize = MAX_STREAMS

const BUFFER_SIZE: usize = BUFFER_SIZE

type ItemType = ItemType

type DerivedItemType = Arc<ItemType>

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

const MAX_STREAMS: usize = MAX_STREAMS

const BUFFER_SIZE: usize = BUFFER_SIZE

type ItemType = ItemType

type DerivedItemType = OgreArc<ItemType, OgreAllocatorType>

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

const MAX_STREAMS: usize = MAX_STREAMS

const BUFFER_SIZE: usize = BUFFER_SIZE

type ItemType = ItemType

type DerivedItemType = OgreArc<ItemType, OgreAllocatorType>

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

const MAX_STREAMS: usize = MAX_STREAMS

const BUFFER_SIZE: usize = BUFFER_SIZE

type ItemType = ItemType

type DerivedItemType = Arc<ItemType>

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

const MAX_STREAMS: usize = MAX_STREAMS

const BUFFER_SIZE: usize = 274_877_906_944usize

type ItemType = ItemType

type DerivedItemType = &'static ItemType