Skip to main content

QueueSet

Trait QueueSet 

Source
pub trait QueueSet<A: Actor>:
    Send
    + Sync
    + 'static {
    // Required methods
    fn entries() -> Vec<QueueEntry<A>>;
    fn dispatch(
        actor: Arc<A>,
        ctx: Ctx<A>,
        name: &str,
        body: &[u8],
    ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>;
}

Required Methods§

Source

fn entries() -> Vec<QueueEntry<A>>

Source

fn dispatch( actor: Arc<A>, ctx: Ctx<A>, name: &str, body: &[u8], ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types§

Source§

impl<A: Actor> QueueSet<A> for ()

Source§

fn entries() -> Vec<QueueEntry<A>>

Source§

fn dispatch( _actor: Arc<A>, _ctx: Ctx<A>, _name: &str, _body: &[u8], ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>

Source§

impl<Act, M0, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, M15> QueueSet<Act> for (M0, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14, M15)

Source§

fn entries() -> Vec<QueueEntry<Act>>

Source§

fn dispatch( actor: Arc<Act>, ctx: Ctx<Act>, name: &str, body: &[u8], ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>

Source§

impl<Act, M0, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14> QueueSet<Act> for (M0, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13, M14)

Source§

fn entries() -> Vec<QueueEntry<Act>>

Source§

fn dispatch( actor: Arc<Act>, ctx: Ctx<Act>, name: &str, body: &[u8], ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>

Source§

impl<Act, M0, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13> QueueSet<Act> for (M0, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12, M13)

Source§

fn entries() -> Vec<QueueEntry<Act>>

Source§

fn dispatch( actor: Arc<Act>, ctx: Ctx<Act>, name: &str, body: &[u8], ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>

Source§

impl<Act, M0, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12> QueueSet<Act> for (M0, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11, M12)

Source§

fn entries() -> Vec<QueueEntry<Act>>

Source§

fn dispatch( actor: Arc<Act>, ctx: Ctx<Act>, name: &str, body: &[u8], ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>

Source§

impl<Act, M0, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11> QueueSet<Act> for (M0, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10, M11)

Source§

fn entries() -> Vec<QueueEntry<Act>>

Source§

fn dispatch( actor: Arc<Act>, ctx: Ctx<Act>, name: &str, body: &[u8], ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>

Source§

impl<Act, M0, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10> QueueSet<Act> for (M0, M1, M2, M3, M4, M5, M6, M7, M8, M9, M10)

Source§

fn entries() -> Vec<QueueEntry<Act>>

Source§

fn dispatch( actor: Arc<Act>, ctx: Ctx<Act>, name: &str, body: &[u8], ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>

Source§

impl<Act, M0, M1, M2, M3, M4, M5, M6, M7, M8, M9> QueueSet<Act> for (M0, M1, M2, M3, M4, M5, M6, M7, M8, M9)

Source§

fn entries() -> Vec<QueueEntry<Act>>

Source§

fn dispatch( actor: Arc<Act>, ctx: Ctx<Act>, name: &str, body: &[u8], ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>

Source§

impl<Act, M0, M1, M2, M3, M4, M5, M6, M7, M8> QueueSet<Act> for (M0, M1, M2, M3, M4, M5, M6, M7, M8)

Source§

fn entries() -> Vec<QueueEntry<Act>>

Source§

fn dispatch( actor: Arc<Act>, ctx: Ctx<Act>, name: &str, body: &[u8], ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>

Source§

impl<Act, M0, M1, M2, M3, M4, M5, M6, M7> QueueSet<Act> for (M0, M1, M2, M3, M4, M5, M6, M7)

Source§

fn entries() -> Vec<QueueEntry<Act>>

Source§

fn dispatch( actor: Arc<Act>, ctx: Ctx<Act>, name: &str, body: &[u8], ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>

Source§

impl<Act, M0, M1, M2, M3, M4, M5, M6> QueueSet<Act> for (M0, M1, M2, M3, M4, M5, M6)

Source§

fn entries() -> Vec<QueueEntry<Act>>

Source§

fn dispatch( actor: Arc<Act>, ctx: Ctx<Act>, name: &str, body: &[u8], ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>

Source§

impl<Act, M0, M1, M2, M3, M4, M5> QueueSet<Act> for (M0, M1, M2, M3, M4, M5)

Source§

fn entries() -> Vec<QueueEntry<Act>>

Source§

fn dispatch( actor: Arc<Act>, ctx: Ctx<Act>, name: &str, body: &[u8], ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>

Source§

impl<Act, M0, M1, M2, M3, M4> QueueSet<Act> for (M0, M1, M2, M3, M4)

Source§

fn entries() -> Vec<QueueEntry<Act>>

Source§

fn dispatch( actor: Arc<Act>, ctx: Ctx<Act>, name: &str, body: &[u8], ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>

Source§

impl<Act, M0, M1, M2, M3> QueueSet<Act> for (M0, M1, M2, M3)

Source§

fn entries() -> Vec<QueueEntry<Act>>

Source§

fn dispatch( actor: Arc<Act>, ctx: Ctx<Act>, name: &str, body: &[u8], ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>

Source§

impl<Act, M0, M1, M2> QueueSet<Act> for (M0, M1, M2)

Source§

fn entries() -> Vec<QueueEntry<Act>>

Source§

fn dispatch( actor: Arc<Act>, ctx: Ctx<Act>, name: &str, body: &[u8], ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>

Source§

impl<Act, M0, M1> QueueSet<Act> for (M0, M1)
where Act: Actor + HandlesQueue<M0> + HandlesQueue<M1>, M0: QueueMessage, M1: QueueMessage,

Source§

fn entries() -> Vec<QueueEntry<Act>>

Source§

fn dispatch( actor: Arc<Act>, ctx: Ctx<Act>, name: &str, body: &[u8], ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>

Source§

impl<Act, M0> QueueSet<Act> for (M0,)
where Act: Actor + HandlesQueue<M0>, M0: QueueMessage,

Source§

fn entries() -> Vec<QueueEntry<Act>>

Source§

fn dispatch( actor: Arc<Act>, ctx: Ctx<Act>, name: &str, body: &[u8], ) -> Option<Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>>>

Implementors§