#

neilyoung2008 · Dec 2, 2019 · 1b9abe7 · 1b9abe7
1 parent 981e97c
commit 1b9abe7
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 34 deletions.
diff --git a/Cargo.toml b/Cargo.toml
@@ -33,7 +33,7 @@ actix-codec = "0.1.2"
 
 actix-web-actors = "1.0.0"
 actix-files = "0.1.1"
-awc = "0.2.1"
+awc = "0.2.8"
 json = "*"
 futures = "0.1"
 bytes = "0.4"

diff --git a/src/qawebsockets/messagesx.rs b/src/qawebsockets/messagesx.rs
diff --git a/src/qawebsockets/websocketclient.rs b/src/qawebsockets/websocketclient.rs
@@ -18,7 +18,6 @@ use futures::{
 };
 
 
-
 pub fn wsmain(wsuri:String) {
  ::std::env::set_var("RUST_LOG", "actix_web=info");
  env_logger::init();
@@ -95,6 +94,12 @@ where
  }
 }
 
+#[derive(Serialize, Deserialize, Debug)]
+struct Peek {
+ aid: String
+}
+
+
 #[derive(Serialize, Deserialize, Debug)]
 struct Broker {
  aid: String,
@@ -128,6 +133,13 @@ where
 
  let u: Broker = serde_json::from_str(&xu).unwrap();
  println!("{}", serde_json::to_string(&u).unwrap());
+ let peek = Peek { aid: "peek_message".to_string()};
+ println!("{:?}", peek);
+ let b = serde_json::to_string(&peek).unwrap();
+ println!("{:?}",b);
+ self.0.write(Message::Text(b)).unwrap();
+
+
  }
  }