subscription_task

zoe_message_store::service

Function subscription_task 

Source 
async fn subscription_task(
    service: Arc<RedisMessageStorage>,
    filters: MessageFilters,
    since: Option<String>,
    limit: Option<usize>,
    subscription: Arc<RwLock<SubscriptionConfig>>,
    sender: UnboundedSender<StreamMessage>,
) -> Result<(), MessageStoreError>