Trait redis_queue::manager::dispatch::Dispatch

pub trait Dispatch {
    type PayloadType: FromRedisValue;
    type Future: Future<Output = TaskResult<Self::PayloadType>>;

    // Required method
    fn send(&self, data: Entry<Self::PayloadType>) -> Self::Future;
}

Interface to dispatch raw message with task information

Required Associated Types

type PayloadType: FromRedisValue

Payload type to use.

type Future: Future<Output = TaskResult<Self::PayloadType>>

Future that performs send.

Required Methods

fn send(&self, data: Entry<Self::PayloadType>) -> Self::Future

Starts send.

Implementations on Foreign Types

impl<T: Dispatch> Dispatch for Box<T>

type PayloadType = <T as Dispatch>::PayloadType

type Future = <T as Dispatch>::Future

fn send(&self, data: Entry<Self::PayloadType>) -> Self::Future

impl<T: Dispatch> Dispatch for Rc<T>

type PayloadType = <T as Dispatch>::PayloadType

type Future = <T as Dispatch>::Future

fn send(&self, data: Entry<Self::PayloadType>) -> Self::Future

impl<T: Dispatch> Dispatch for Arc<T>

type PayloadType = <T as Dispatch>::PayloadType

type Future = <T as Dispatch>::Future

fn send(&self, data: Entry<Self::PayloadType>) -> Self::Future

Implementors