fix test in async

because the api change ,fix the marco in prost

Signed-off-by: jokemanfire <hu.dingyang@zte.com.cn>

Author: jokemanfire

.gitignore

@@ -7,4 +7,5 @@ Cargo.lock
 *.o
 example/protocols/**/*.rs
 src/ttrpc.rs
-example2/protocols/**/*.rs
+example2/protocols/**/*.rs
+!example2/protocols/**/mod.rs

Makefile

@@ -25,7 +25,6 @@ build: debug
 test:
 
 ifeq ($OS,Windows_NT)
-	# async isn't enabled for windows, don't test that feature
 	cargo test --features sync,async,rustprotobuf
 else
 	# cargo test --all-features --verbose
@@ -38,7 +37,12 @@ endif
 check:
 	cargo fmt --all -- --check
 	cargo clippy --all-targets --features sync,async -- -D warnings
+	# Skip prost check on Windows
+ifeq ($(OS),Windows_NT)
+	@echo "Skipping prost check on Windows"
+else
 	cargo clippy --all-targets --no-default-features --features sync,async,prost -- -D warnings
+endif
 
 .PHONY: check-all
 check-all:

example/Cargo.toml

@@ -13,7 +13,7 @@ description = "An example of ttrpc."
 [dev-dependencies]
 protobuf = "3.1.0"
 bytes = "0.4.11"
-libc = "0.2.79"
+libc = "0.2.158"
 byteorder = "1.3.2"
 log = "0.4.6"
 simple-logging = "2.0.2"

example2/async_client.rs

@@ -12,7 +12,7 @@ use ttrpc::r#async::Client;
 
 #[tokio::main(flavor = "current_thread")]
 async fn main() {
-    let c = Client::connect(utils::SOCK_ADDR).unwrap();
+    let c = Client::connect(utils::SOCK_ADDR).await.unwrap();
     let hc = health::HealthClient::new(c.clone());
     let ac = agent::AgentServiceClient::new(c);
 

example2/async_stream_client.rs

@@ -14,7 +14,7 @@ use ttrpc::r#async::Client;
 async fn main() {
     simple_logging::log_to_stderr(log::LevelFilter::Info);
 
-    let c = Client::connect(utils::SOCK_ADDR).unwrap();
+    let c = Client::connect(utils::SOCK_ADDR).await.unwrap();
     let sc = streaming::StreamingClient::new(c);
 
     let _now = std::time::Instant::now();

example2/protocols/asynchronous/mod.rs

@@ -0,0 +1,8 @@
+// Copyright (c) 2020 Ant Financial
+//
+// SPDX-License-Identifier: Apache-2.0
+//
+
+#![allow(dead_code)]
+
+include!("_include.rs");

example2/protocols/sync/mod.rs

@@ -0,0 +1,8 @@
+// Copyright (c) 2020 Ant Financial
+//
+// SPDX-License-Identifier: Apache-2.0
+//
+
+#![allow(dead_code)]
+
+include!("_include.rs");

src/asynchronous/utils.rs

@@ -434,7 +434,7 @@ macro_rules! async_client_stream_receive {
             .map_err(::ttrpc::err_to_others!(e, "Encoding error "))?;
 
         let inner = $self.client.new_stream(creq, false, true).await?;
-        let stream = ::ttrpc::r#async::ClientStreamReceiver::new(inner);
+        let stream = ::ttrpc::r#async::ClientStreamReceiver::new(inner, $self.client.clone());
 
         return Ok(stream);
     };