pub trait SyncManagerProxyInterface: Send + Sync {
type WaitForBarrierThresholdResponseFut: Future<Output = Result<bool, Error>> + Send;
// Required methods
fn bus_subscribe(
&self,
bus_name: &str,
client_name: &str,
bus: ServerEnd<BusMarker>,
) -> Result<(), Error>;
fn wait_for_barrier_threshold(
&self,
barrier_name: &str,
threshold: u32,
timeout: i64,
) -> Self::WaitForBarrierThresholdResponseFut;
}