Method start

dubbo/src/framework.rs:110–145

(&mut self)

    }

    pub async fn start(&mut self) {
        self.init().unwrap();
        info!("starting...");
        // TODO: server registry

        let mut registry_extensions = Vec::new();

        for registry_url in &self.registries {
            let registry_url = registry_url.clone();
            let registry_extension = extension::EXTENSIONS.load_registry(registry_url).await;
            if let Ok(registry_extension) = registry_extension {
                registry_extensions.push(registry_extension);
            }
        }

        let mem_reg = Box::new(
            RegistryProtocol::new()
                .with_registries(registry_extensions.clone())
                .with_services(self.service_registry.clone()),
        );
        let mut async_vec: Vec<Pin<Box<dyn Future<Output = BoxExporter> + Send>>> = Vec::new();
        for (name, items) in self.protocols.iter() {
            for url in items.iter() {
                info!("base: {:?}, service url: {:?}", name, url);
                let exporter = mem_reg.clone().export(url.to_owned());
                async_vec.push(exporter);

                //TODO multiple registry
                for registry_extension in &registry_extensions {
                    let _ = registry_extension.register(url.clone()).await;
                }
            }
        }

        let _res = future::join_all(async_vec).await;
    }
}

impl Drop for Dubbo {