Trait frame_support::traits::EnqueueMessage

pub trait EnqueueMessage<Origin: MaxEncodedLen> {
    type MaxMessageLen: Get<u32>;

    fn enqueue_message(
        message: BoundedSlice<'_, u8, Self::MaxMessageLen>,
        origin: Origin
    );
    fn enqueue_messages<'a>(
        messages: impl Iterator<Item = BoundedSlice<'a, u8, Self::MaxMessageLen>>,
        origin: Origin
    );
    fn sweep_queue(origin: Origin);
    fn footprint(origin: Origin) -> Footprint;
}

Can enqueue messages for multiple origins.

Required Associated Types

type MaxMessageLen: Get<u32>

The maximal length any enqueued message may have.

Required Methods

fn enqueue_message(
    message: BoundedSlice<'_, u8, Self::MaxMessageLen>,
    origin: Origin
)

Enqueue a single message from a specific origin.

fn enqueue_messages<'a>(
    messages: impl Iterator<Item = BoundedSlice<'a, u8, Self::MaxMessageLen>>,
    origin: Origin
)

Enqueue multiple messages from a specific origin.

fn sweep_queue(origin: Origin)

Any remaining unprocessed messages should happen only lazily, not proactively.

fn footprint(origin: Origin) -> Footprint

Return the state footprint of the given queue.

Implementations on Foreign Types

impl<Origin: MaxEncodedLen> EnqueueMessage<Origin> for ()

type MaxMessageLen = ConstU32<0>

fn enqueue_message(_: BoundedSlice<'_, u8, Self::MaxMessageLen>, _: Origin)

fn enqueue_messages<'a>(
    _: impl Iterator<Item = BoundedSlice<'a, u8, Self::MaxMessageLen>>,
    _: Origin
)

fn sweep_queue(_: Origin)

fn footprint(_: Origin) -> Footprint

Implementors

impl<E: EnqueueMessage<O>, O: MaxEncodedLen, N: MaxEncodedLen, C: Convert<N, O>> EnqueueMessage<N> for TransformOrigin<E, O, N, C>

type MaxMessageLen = <E as EnqueueMessage<O>>::MaxMessageLen