Add test for kv::create

nats/tests/kv.rs

@@ -301,6 +301,35 @@ fn key_value_purge() {
     assert_eq!(entries.into_iter().count(), 1);
 }
 
+#[test]
+fn key_value_create() {
+    let server = nats_server::run_server("tests/configs/jetstream.conf");
+    let client = nats::connect(server.client_url()).unwrap();
+    let context = nats::jetstream::new(client);
+
+    let bucket = context
+        .create_key_value(&Config {
+            bucket: "FOO".to_string(),
+            history: 10,
+            ..Default::default()
+        })
+        .unwrap();
+
+    let create = bucket.create("foo", "1");
+    assert!(create.is_ok());
+
+    let create = bucket.create("foo", "1");
+    assert!(create.is_err());
+
+    bucket.delete("foo").unwrap();
+    let create = bucket.create("foo", "1");
+    assert!(create.is_ok());
+
+    bucket.purge("foo").unwrap();
+    let create = bucket.create("foo", "1");
+    assert!(create.is_ok());
+}
+
 #[test]
 fn key_value_keys() {
     let server = nats_server::run_server("tests/configs/jetstream.conf");