Function producer 

pub fn producer<T: Send + Sync + 'static>(rx: Receiver<T>) -> StreamProducer<T>