adding superstream error-case test

Author: DanielePalaia

tests/integration/client_test.rs

@@ -73,7 +73,49 @@ async fn client_create_and_delete_super_stream_test() {
 
     let _ = client.close().await;
 }
+#[tokio::test(flavor = "multi_thread")]
+async fn client_create_super_stream_error_test() {
+    let super_stream_name = "test-super-stream-error";
+
+    let client = Client::connect(ClientOptions::default()).await.unwrap();
+
+    let partitions: Vec<String> = [
+        "test-super-stream-error-0",
+        "test-super-stream-error-1",
+        "test-super-stream-error-2",
+    ]
+    .iter()
+    .map(|&x| x.into())
+    .collect();
+
+    let binding_keys: Vec<String> = ["0", "1", "2"].iter().map(|&x| x.into()).collect();
+
+    let response = client
+        .create_super_stream(
+            &super_stream_name,
+            partitions.clone(),
+            binding_keys.clone(),
+            HashMap::new(),
+        )
+        .await
+        .unwrap();
 
+    assert_eq!(&ResponseCode::Ok, response.code());
+
+    let response = client
+        .create_super_stream(&super_stream_name, partitions, binding_keys, HashMap::new())
+        .await
+        .unwrap();
+
+    assert_eq!(&ResponseCode::StreamAlreadyExists, response.code());
+
+    let response = client
+        .delete_super_stream(&super_stream_name)
+        .await
+        .unwrap();
+
+    assert_eq!(&ResponseCode::Ok, response.code());
+}
 async fn client_delete_stream_test() {
     let test = TestClient::create().await;