Function spawn_stream 

pub fn spawn_stream<M, F>(
    params: StreamParams<M, F>,
    cancel: CancellationToken,
) -> StreamHandle
where
    M: Send + 'static,
    F: Send + 'static,

Starts the supervisor task. cancel should be a child of the connector’s root token.

Must be called inside a Tokio runtime. See the module docs for a complete example.