British-Information-Technologies
/
ChatKit-server
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Update client.rs 

minor bug fixes
This commit is contained in:
michael-bailey 2022-06-17 08:54:18 +02:00
parent 306526e1c2
commit 224bdbc23a
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
server/src/client_management/client.rs
View File

@ -33,8 +33,8 @@ use crate::{
ConnectionOuput,
},
prelude::{
ObservableMessage,
ObservableMessage::{Subscribe, Unsubscribe},
messages::ObservableMessage,
messages::ObservableMessage::{Subscribe, Unsubscribe},
},
};
@ -165,7 +165,7 @@ impl Actor for Client {
use ConnectionMessage::SendData;
println!("[Client] started");
self.connection
.do_send(Subscribe(ctx.address().recipient()));
.do_send::<ObservableMessage<ConnectionOuput>>(Subscribe(ctx.address().recipient()));
self.connection.do_send(SendData(
to_string::<ClientStreamOut>(&Connected).unwrap(),
));
@ -175,7 +175,7 @@ impl Actor for Client {
use ClientStreamOut::Disconnected;
use ConnectionMessage::SendData;
self.connection
.do_send(Unsubscribe(ctx.address().recipient()));
.do_send::<ObservableMessage<ConnectionOuput>>(Unsubscribe(ctx.address().recipient()));
self.connection.do_send(SendData(
to_string::<ClientStreamOut>(&Disconnected).unwrap(),
));