Trait fxa_email_service::queues::Incoming

pub trait Incoming: Debug + Sync {
    fn receive(
        &'static self
    ) -> Box<dyn Future<Item = Vec<Message>, Error = AppError>>;
    fn delete(
        &'static self, 
        message: Message
    ) -> Box<dyn Future<Item = (), Error = AppError>>;
}

An incoming bounce/complaint queue.

Required Methods

fn receive(
    &'static self
) -> Box<dyn Future<Item = Vec<Message>, Error = AppError>>

fn delete(
    &'static self,
    message: Message
) -> Box<dyn Future<Item = (), Error = AppError>>

Implementors

impl Incoming for Queue

fn receive(     &'static self ) -> Box<dyn Future<Item = Vec<Message>, Error = AppError>>

fn delete(     &'static self,     message: Message ) -> Box<dyn Future<Item = (), Error = AppError>>