in registry/zookeeper/src/lib.rs [99:113]
fn create_listener(
&self,
path: String,
service_name: String,
listener: RegistryNotifyListener,
) -> ServiceInstancesChangedListener {
let mut service_names = HashSet::new();
service_names.insert(service_name.clone());
ServiceInstancesChangedListener {
zk_client: Arc::clone(&self.zk_client),
path,
service_name: service_name.clone(),
listener,
}
}