diff options
| author |  cel 🌸 <cel@bunny.garden> | 2024-12-22 18:58:28 +0000 |
|---|---|---|
| committer | cel 🌸 <cel@bunny.garden> | 2024-12-22 18:58:28 +0000 |
| commit | 6385e43e8ca467e53c6a705a932016c5af75c3a2 (patch) | |
| tree | f63fb7bd9a349f24b093ba4dd037c6ce7789f5ee /jabber/src/jabber_stream.rs | |
| parent | 595d165479b8b12e456f39205d8433b822b07487 (diff) | |
| download | luz-6385e43e8ca467e53c6a705a932016c5af75c3a2.tar.gz luz-6385e43e8ca467e53c6a705a932016c5af75c3a2.tar.bz2 luz-6385e43e8ca467e53c6a705a932016c5af75c3a2.zip | |
implement sink and stream with tokio::spawn
Diffstat (limited to 'jabber/src/jabber_stream.rs')
| -rw-r--r-- | jabber/src/jabber_stream.rs | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/jabber/src/jabber_stream.rs b/jabber/src/jabber_stream.rs index d981f8f..89890a8 100644 --- a/jabber/src/jabber_stream.rs +++ b/jabber/src/jabber_stream.rs @@ -27,7 +27,7 @@ pub mod bound_stream; // open stream (streams started) pub struct JabberStream<S> { reader: Reader<ReadHalf<S>>, - writer: Writer<WriteHalf<S>>, + pub(crate) writer: Writer<WriteHalf<S>>, } impl<S> JabberStream<S> @@ -368,12 +368,12 @@ mod tests { async fn sink() { let mut client = JabberClient::new("test@blos.sm", "slayed").unwrap(); client.connect().await.unwrap(); - let stream = client.inner().unwrap(); - let sink = sink::unfold(stream, |mut stream, stanza: Stanza| async move { - stream.writer.write(&stanza).await?; - Ok::<JabberStream<Tls>, Error>(stream) - }); - todo!() + // let stream = client.inner().unwrap(); + // let sink = sink::unfold(stream, |mut stream, stanza: Stanza| async move { + // stream.writer.write(&stanza).await?; + // Ok::<JabberStream<Tls>, Error>(stream) + // }); + // todo!() // let _jabber = Connection::connect_user("test@blos.sm", "slayed".to_string()) // .await // .unwrap() |