pub trait WatcherProxyInterface: Send + Sync { type WatchResponseFut: Future<Output = Result<u64, Error>> + Send; // Required method fn watch(&self) -> Self::WatchResponseFut; }