pub async fn run_sender(
receiver: UnboundedReceiver<TracingMessage>,
send_stream: SendStream,
cancellation_token: CancellationToken,
) -> Result<()>pub async fn run_sender(
receiver: UnboundedReceiver<TracingMessage>,
send_stream: SendStream,
cancellation_token: CancellationToken,
) -> Result<()>