pub type MessageFetcher = Arc<dyn Fn() -> BoxFuture<'static, Vec<Message>> + Send + Sync + 'static>;
Async fetcher for queued messages (steering or follow-up).
pub struct MessageFetcher { /* private fields */ }