Struct InboxBuilder 

pub struct InboxBuilder<E: Send + 'static> { /* private fields */ }

Implementations

impl<E: Send + 'static> InboxBuilder<E>

pub fn name(self, n: impl Into<String>) -> Self

pub fn key<F>(self, f: F) -> Self

where F: Fn(&E) -> String + Send + Sync + 'static,

Closure that derives the idempotency key from a message.

pub fn source(self, rx: UnboundedReceiver<E>) -> Self

Inbound message source.

pub fn handler<F, Fut>(self, f: F) -> Self

where F: Fn(E) -> Fut + Send + Sync + 'static, Fut: Future<Output = bool> + Send + 'static,

Handler for not-yet-seen messages. Returning true marks the message as processed; false leaves it unmarked so a retry can re-attempt processing.

pub fn store<S: InboxStore>(self, store: Arc<S>) -> Self

pub fn build(self) -> Result<InboxTopology<E>, PatternError<()>>