This commit is contained in:
faldor20 2024-02-03 21:06:09 +10:00
parent 718e611c22
commit 32f73b7ea1
No known key found for this signature in database
GPG key ID: F2216079B890CD57

View file

@ -50,13 +50,11 @@ impl RocServer {
pub fn new(client: Client) -> Self { pub fn new(client: Client) -> Self {
let registry_config = RegistryConfig { let registry_config = RegistryConfig {
latest_document_timeout: Duration::from_millis( latest_document_timeout: Duration::from_millis(
read_env_num("ROCLS_LATEST_DOC_TIMEOUT_MS").unwrap_or_else(|| 5000), read_env_num("ROCLS_LATEST_DOC_TIMEOUT_MS").unwrap_or(5000),
), ),
}; };
let config = RocServerConfig { let config = RocServerConfig {
debounce_ms: Duration::from_millis( debounce_ms: Duration::from_millis(read_env_num("ROCLS_DEBOUNCE_MS").unwrap_or(100)),
read_env_num("ROCLS_DEBOUNCE_MS").unwrap_or_else(|| 100),
),
}; };
Self { Self {
state: RocServerState::new(config, Registry::new(registry_config)), state: RocServerState::new(config, Registry::new(registry_config)),
@ -124,7 +122,8 @@ impl RocServer {
debug!("Cancelled change. Reason:{:?}", e); debug!("Cancelled change. Reason:{:?}", e);
return; return;
} }
debug!("Applied_change getting and returning diagnostics");
debug!("Applied_changes getting and returning diagnostics");
let diagnostics = self.state.registry.diagnostics(&fi).await; let diagnostics = self.state.registry.diagnostics(&fi).await;