Hole/core
Hole/core
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

find out way to communicate

Browse source
This commit is contained in:
Horhik 2020-11-22 18:19:32 +02:00
parent 4916f96345
commit ddcc5e48a8
2 changed files with 31 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/chat/front_conn.rs
View file

@ -9,7 +9,7 @@ use async_tungstenite::{accept_async, tungstenite::Message, WebSocketStream};
use futures::{SinkExt, StreamExt}; use futures::{SinkExt, StreamExt};
use serde_derive::Deserialize; use serde_derive::Deserialize;
use std::env; use std::env;
pub fn listen_client() -> io::Result<()> { pub fn listen_client(sync: std::sync::mpsc::Sender) -> io::Result<()> {
task::block_on(connect_to_client()) task::block_on(connect_to_client())
} }

30
src/main.rs
View file

@ -12,6 +12,34 @@ use std::{
}, },
thread, thread,
}; };
/*
+-----------------------------------------------------------------------------------+
| Client |
| |
| |
| +----------------------------+ +---------------------------------+ |
| | Thread 1 | | Thread 2 | | +-------------------+
+--------------+ | | +-----------------------+ | | +--------------------------+ | | | |
| | | | | Decode -----------------------> | | | | |
| ----------------------------> | | | | to JSON --------------------------------> |
| | | | | | | | | | | | | |
| | | | | | | | | | | | | |
| | | | +-----------------------+ | | | | | | | |
| Server | | | | | +--------------------------+ | | | Frontend |
| | | | | | | | | |
| | | | +----------------------+ | | +-----------------------------+ | | | |
| | | | | | | | | | | | | |
| | | | | Encode | | | | | | | | |
| | | | | <----------------------------- from JSON <-------------------------------- |
| | | | | | | | | | | | | |
| | | | +----------------------+ | | +-----------------------------+ | | | |
+--------------+ | | | | | | | |
| +----------------------------+ +---------------------------------+ | +-------------------+
| |
| |
+-----------------------------------------------------------------------------------+
*/
fn main() -> io::Result<()> { fn main() -> io::Result<()> {
// listen_client(); // listen_client();
@ -34,6 +62,8 @@ fn main() -> io::Result<()> {
let (server_sender, server_receiver): (Sender<MFA>, Receiver<MFA>) = mpsc::channel(); // server sender, server receiver let (server_sender, server_receiver): (Sender<MFA>, Receiver<MFA>) = mpsc::channel(); // server sender, server receiver
let (client_sender, client_receiver): (Sender<MFA>, Receiver<MFA>) = mpsc::channel(); // client sender, client receiver let (client_sender, client_receiver): (Sender<MFA>, Receiver<MFA>) = mpsc::channel(); // client sender, client receiver
thread::spawn(listen_client(server_sender));
let client_listener = thread::spawn(move || { let client_listener = thread::spawn(move || {
let new_msg: MFA = client_receiver.recv().unwrap(); let new_msg: MFA = client_receiver.recv().unwrap();
println!("{:?}", new_msg.encoded_msg); println!("{:?}", new_msg.encoded_msg);