pub type FlowFuture<'a> = Pin<Box<dyn Future<Output = Result<Message, AgentError>> + Send + 'a>>;
pub struct FlowFuture<'a> { /* private fields */ }