refine

Author: alissa-tung

src/hstreamdb/tests/common.rs

@@ -13,7 +13,7 @@ pub async fn init_client() -> anyhow::Result<Client> {
     Ok(Client(client))
 }
 
-pub struct Client(hstreamdb::Client);
+pub struct Client(pub hstreamdb::Client);
 
 impl Client {
     pub async fn new_stream(&self) -> anyhow::Result<Stream> {

src/hstreamdb/tests/tls_test.rs

@@ -1,3 +1,5 @@
+mod common;
+
 use std::env;
 
 use hstreamdb::tls::{Certificate, ClientTlsConfig, Identity};
@@ -36,4 +38,12 @@ async fn test_tls_impl() {
     .unwrap();
 
     log::info!("{:?}", client.list_streams().await.unwrap());
+
+    let client = common::Client(client);
+
+    let (stream, _sub) = client.new_stream_subscription().await.unwrap();
+    client
+        .write_rand(stream.stream_name, 10, 2000, 1000)
+        .await
+        .unwrap();
 }