Function source_from_unbounded 

pub fn source_from_unbounded<T: Send + 'static>(
    rx: UnboundedReceiver<T>,
) -> Source<T>

Wrap a tokio::sync::mpsc::UnboundedReceiver as a streams Source.

Callers send work into the matching UnboundedSender; the source terminates when every sender is dropped.