use tokio::sync::oneshot; #[derive(Debug)] pub struct Message { pub req: R, pub rsp_sender: oneshot::Sender>, pub span: tracing::Span, }