cel
/
luz
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

stream and sink split

This commit is contained in:
cel 🌸 2024-12-22 19:55:48 +00:00
parent 6385e43e8c
commit 27f90bd85f
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
jabber/src/client.rs
View File

@ -349,12 +349,11 @@ mod tests {
sleep(Duration::from_secs(5)).await; sleep(Duration::from_secs(5)).await;
let jid = client.jid.clone(); let jid = client.jid.clone();
let server = client.server.clone(); let server = client.server.clone();
let mut client = Arc::new(Mutex::new(client)); let (mut write, mut read) = client.split();
tokio::join!( tokio::join!(
async { async {
let mut client = client.lock().await; write
client
.send(Stanza::Iq(Iq { .send(Stanza::Iq(Iq {
from: Some(jid.clone()), from: Some(jid.clone()),
id: "c2s1".to_string(), id: "c2s1".to_string(),
@ -365,10 +364,7 @@ mod tests {
errors: Vec::new(), errors: Vec::new(),
})) }))
.await; .await;
}, write
async {
let mut client = client.lock().await;
client
.send(Stanza::Iq(Iq { .send(Stanza::Iq(Iq {
from: Some(jid.clone()), from: Some(jid.clone()),
id: "c2s2".to_string(), id: "c2s2".to_string(),
@ -381,7 +377,7 @@ mod tests {
.await; .await;
}, },
async { async {
while let Some(stanza) = client.lock().await.next().await { while let Some(stanza) = read.next().await {
info!("{:#?}", stanza); info!("{:#?}", stanza);
} }
} }