Function broker_emitter 

pub fn broker_emitter(
    broker: Arc<Broker>,
    block_id: String,
) -> Arc<dyn Fn(&FsOpEvent) + Send + Sync> 

The Emit that publishes files:op to block:<block_id>.