Function source 

pub fn source<C, O>(capacity: usize) -> (Sender<O>, Source<C, O>)
where
    C: Context,
    O: Send + Sync,

Create a channel-backed source node and its sender handle.

capacity sets the mpsc buffer size. Returns (sender, source_node).