Add some comments to the code

nats-io · Feb 2, 2024 · e88df36 · e88df36
1 parent 3ca6689
commit e88df36
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/async-nats/src/jetstream/kv/mod.rs b/async-nats/src/jetstream/kv/mod.rs
@@ -243,7 +243,10 @@ impl Store {
         let entry = self.entry(key.as_ref()).await?;
 
         match entry {
+            // key does not exist update with 0 revision to create it.
             None => Ok(self.update(key, value, 0).await?),
+
+            // deleted or Purged key, we can create it again.
             Some(Entry {
                 operation: Operation::Delete | Operation::Purge,
                 ..
@@ -252,6 +255,7 @@ impl Store {
                 Ok(revision)
             }
 
+            // key already exists.
             Some(_) => Err(CreateError::new(CreateErrorKind::AlreadyExists)),
         }
     }