Update the inline docs in rs files

Author: Jove Zhong

src/lib/fetch.rs

@@ -23,7 +23,7 @@ impl ProtonClient {
     /// let client = ProtonClient::new("http://localhost:8123");
     ///
     ///  let mut cursor = client
-    ///     .fetch::<MyRow<'_>>("SELECT ?fields from table(some) WHERE no BETWEEN 500 AND 504")
+    ///     .fetch::<MyRow<'_>>("SELECT ?fields from table(test_stream) WHERE no BETWEEN 500 AND 504")
     ///     .await
     ///     .expect("[main/fetch]: Failed to fetch data");
     ///
@@ -64,7 +64,7 @@ impl ProtonClient {
     ///
     /// let client = ProtonClient::new("http://localhost:8123");
     ///
-    /// let query = "SELECT ?fields FROM some WHERE no BETWEEN 0 AND 1";
+    /// let query = "SELECT ?fields FROM test_stream WHERE no BETWEEN 0 AND 1";
     /// let data = client.fetch_all::<MyRow>(query).await.unwrap();
     ///
     /// println!("Received {} records", data.len());
@@ -100,7 +100,7 @@ impl ProtonClient {
     /// async fn example() -> Result<()> {
     ///
     /// let client = ProtonClient::new("http://localhost:8123");
-    /// let query = "select count() from table(table_name)";
+    /// let query = "select count() from table(test_stream)";
     /// let item = client.fetch_one::<u64>(query).await.unwrap();
     ///
     /// println!("Single result: {:#?}", item);
@@ -143,7 +143,7 @@ impl ProtonClient {
     ///
     /// let client = ProtonClient::new("http://localhost:8123");
     /// let item_id = 42;
-    /// let query = "SELECT ?fields FROM some WHERE no = 42";
+    /// let query = "SELECT ?fields FROM test_stream WHERE no = 42";
     /// let item = client.fetch_optional::<MyRow>(query).await.unwrap();
     ///
     /// match item {

src/lib/getters.rs

@@ -14,7 +14,7 @@ impl ProtonClient {
     ///
     /// async fn example() -> Result<()> {
     ///
-    /// let client = ProtonClient::new("https://api.proton.com");
+    /// let client = ProtonClient::new("http://localhost:8123");
     ///
     /// let url = client.client().await;
     ///
@@ -37,11 +37,11 @@ impl ProtonClient {
     ///
     /// async fn example() -> Result<()> {
     ///
-    /// let client = ProtonClient::new("https://api.proton.com");
+    /// let client = ProtonClient::new("http://localhost:8123");
     ///
     /// let url = client.url().await;
     ///
-    /// assert_eq!(url, "https://api.proton.com");
+    /// assert_eq!(url, "http://localhost:8123");
     ///
     /// Ok(())
     /// }

src/lib/insert.rs

@@ -37,7 +37,7 @@ impl ProtonClient {
     ///
     ///  async fn example() -> Result<()> {
     ///
-    ///     let client = ProtonClient::new("http://localhost:8080");
+    ///     let client = ProtonClient::new("http://localhost:8123");
     ///     let mut insert = client.insert("table_name").await?;
     ///
     ///    insert
@@ -85,7 +85,7 @@ impl ProtonClient {
     ///
     ///  async fn example() -> Result<()> {
     ///
-    ///     let client = ProtonClient::new("http://localhost:8080");
+    ///     let client = ProtonClient::new("http://localhost:8123");
     ///      let mut inserter = client
     ///         .inserter("table_name")
     ///         .await

src/lib/query.rs

@@ -28,7 +28,7 @@ impl ProtonClient {
     ///  let client = ProtonClient::new("http://localhost:8123");
     ///
     ///      client
-    ///         .execute_query("CREATE STREAM IF NOT EXISTS some(no uint32, name string) ORDER BY no")
+    ///         .execute_query("CREATE STREAM IF NOT EXISTS test_stream(no uint32, name string) ORDER BY no")
     ///         .await
     ///         .expect("Failed to execute query");
     ///