fn create_listener()

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,
        }
    }