Function dipstick::publish_every

pub fn publish_every<E, M, S>(
    duration: Duration, 
    source: AggregateSource, 
    target: S, 
    export: E
) -> CancelHandle where
    S: Sink<M> + 'static + Send + Sync,
    M: Clone + Send + Sync,
    E: Fn(Kind, &str, ScoreType) -> Option<(Kind, Vec<&str>, Value)> + Send + Sync + 'static, 

Schedules the publisher to run at recurrent intervals