Function plugin 

pub fn plugin<F>(f: F) -> FlowStage
where
    F: Fn(&mut Emit<'_>, Option<FlowValue>) -> Result<Option<FlowValue>> + Send + Sync + 'static,