From 728377a447219ed4c8ef5e9399dd68d08897f3b6 Mon Sep 17 00:00:00 2001
From: Nikolay Kim <fafhrd91@gmail.com>
Date: Thu, 8 Feb 2018 20:55:34 -0800
Subject: [PATCH] fix example

---
 examples/websocket-chat/src/main.rs    | 2 +-
 examples/websocket-chat/src/server.rs  | 4 ++--
 examples/websocket-chat/src/session.rs | 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/examples/websocket-chat/src/main.rs b/examples/websocket-chat/src/main.rs
index 509192f0..9c9af18e 100644
--- a/examples/websocket-chat/src/main.rs
+++ b/examples/websocket-chat/src/main.rs
@@ -64,7 +64,7 @@ impl Actor for WsChatSession {
         // routes within application
         let addr: SyncAddress<_> = ctx.address();
         ctx.state().addr.call(
-            self, server::Connect{addr: addr.into_subscriber()}).then(
+            self, server::Connect{addr: addr.into()}).then(
             |res, act, ctx| {
                 match res {
                     Ok(Ok(res)) => act.id = res,
diff --git a/examples/websocket-chat/src/server.rs b/examples/websocket-chat/src/server.rs
index 4eae86d0..477a401b 100644
--- a/examples/websocket-chat/src/server.rs
+++ b/examples/websocket-chat/src/server.rs
@@ -13,7 +13,7 @@ use session;
 
 /// New chat session is created
 pub struct Connect {
-    pub addr: Box<actix::Subscriber<session::Message> + Send>,
+    pub addr: SyncSubscriber<session::Message>,
 }
 
 /// Response type for Connect message
@@ -61,7 +61,7 @@ pub struct Join {
 /// `ChatServer` manages chat rooms and responsible for coordinating chat session.
 /// implementation is super primitive
 pub struct ChatServer {
-    sessions: HashMap<usize, Box<actix::Subscriber<session::Message> + Send>>,
+    sessions: HashMap<usize, SyncSubscriber<session::Message>>,
     rooms: HashMap<String, HashSet<usize>>,
     rng: RefCell<ThreadRng>,
 }
diff --git a/examples/websocket-chat/src/session.rs b/examples/websocket-chat/src/session.rs
index 5bc799ca..29fcb989 100644
--- a/examples/websocket-chat/src/session.rs
+++ b/examples/websocket-chat/src/session.rs
@@ -46,7 +46,7 @@ impl Actor for ChatSession {
         // future within context, but context waits until this future resolves
         // before processing any other events.
         let addr: SyncAddress<_> = ctx.address();
-        self.addr.call(self, server::Connect{addr: addr.into_subscriber()})
+        self.addr.call(self, server::Connect{addr: addr.into()})
             .then(|res, act, ctx| {
                 match res {
                     Ok(Ok(res)) => act.id = res,