async fn stream_async( uri: ProxyUri, tx: &Sender<LogMsg>, on_msg: Option<Box<dyn Fn() + Send + Sync>>, ) -> Result<(), StreamError>