Commit 90fb3be

committed

specify the address to send

1 parent 2634459 commit 90fb3beCopy full SHA for 90fb3be

File tree

-6

lines changed

-6

lines changed

Lines changed: 9 additions & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -8,10 +8,10 @@ use tokio::{`
`8`	`8`	`async fn main() {`
`9`	`9`	`let listener = TcpListener::bind("localhost:8080").await.unwrap();`
`10`	`10`
`11`		`- let (tx, _rx) = broadcast::channel::<String>(10);`
	`11`	`+ let (tx, _rx) = broadcast::channel(10);`
`12`	`12`
`13`	`13`	`loop {`
`14`		`- let (mut socket, _addr) = listener.accept().await.unwrap();`
	`14`	`+ let (mut socket, addr) = listener.accept().await.unwrap();`
`15`	`15`
`16`	`16`	`let tx = tx.clone();`
`17`	`17`	`let mut rx = tx.subscribe();`
`@@ -29,14 +29,17 @@ async fn main() {`
`29`	`29`	`break;`
`30`	`30`	`}`
`31`	`31`
`32`		`- tx.send(line.clone()).unwrap();`
	`32`	`+ tx.send((line.clone(), addr)).unwrap();`
`33`	`33`	`line.clear();`
`34`	`34`	`}`
`35`	`35`	`result = rx.recv() => {`
`36`		`- let msg = result.unwrap();`
	`36`	`+ let (msg, other_addr) = result.unwrap();`
	`37`	`+`
	`38`	`+ if addr != other_addr{`
	`39`	`+ // write every single byte in the buffer`
	`40`	`+ writer.write_all(msg.as_bytes()).await.unwrap();`
	`41`	`+ }`
`37`	`42`
`38`		`- // write every single byte in the buffer`
`39`		`- writer.write_all(msg.as_bytes()).await.unwrap();`
`40`	`43`	`}`
`41`	`44`	`}`
`42`	`45`	`}`

Comments

(0)