[websocket]How to implement peer-to-peer sending

[gudaoxuri]

I saw an example of broadcast, how can I implement send to someone (E.g. a send to b, b send to c)?

[gudaoxuri]

Could you add a sample project or tell me how to implement it? Thank you!

poem/examples/poem/websocket-chat/src/main.rs

Lines 70 to 90 in 9bd08d1

	ws.on_upgrade(move |socket| async move {
	let (mut sink, mut stream) = socket.split();
	tokio::spawn(async move {
	while let Some(Ok(msg)) = stream.next().await {
	if let Message::Text(text) = msg {
	if sender.send(format!("{}: {}", name, text)).is_err() {
	break;
	}
	}
	}
	});
	tokio::spawn(async move {
	while let Ok(msg) = receiver.recv().await {
	if sink.send(Message::Text(msg)).await.is_err() {
	break;
	}
	}
	});
	})

I want to add the recipient's information to sender.send on line 76, then get the recipient's information before sink.send on line 85, and determine whether the current sink is the recipient. But this thought doesn't seem to work.

[gudaoxuri]

Any suggestions, please?

[gudaoxuri]

Problem solved