pub type CatchUpStream = UnboundedReceiver<CatchUpResponse>;
pub struct CatchUpStream { /* private fields */ }