Trait DeliveryStream 

pub trait DeliveryStream:
    Stream<Item = Result<Box<dyn Delivery>, Box<dyn DeliveryError>>>
    + Unpin
    + Send { }

The stream type that the Celery app will consume deliveries from.

AMQP broker supports Send + Sync with lapin 3.6.0+, but Redis broker still has limitations due to underlying redis-rs and deadpool-redis clients not being fully Sync. TODO: Consider alternative Redis client that supports Sync or use different async patterns

Implementors