Function dipstick::publish::publish_every

pub fn publish_every<M, S>(
    duration: Duration, 
    source: AggregateSource, 
    target: S
) where
    S: Sink<M> + 'static + Send + Sync,
    M: Send + Sync, 

Schedules the publisher to run at recurrent intervals