pub trait MessageSourceProxyInterface: Send + Sync {
type ReceiveMessagesResponseFut: Future<Output = Result<(), Error>> + Send;
type ReceiveBatonResponseFut: Future<Output = Result<LeaseBaton, Error>> + Send;
// Required methods
fn receive_messages(
&self,
socket: Socket,
) -> Self::ReceiveMessagesResponseFut;
fn receive_baton(&self) -> Self::ReceiveBatonResponseFut;
}