From 6385e43e8ca467e53c6a705a932016c5af75c3a2 Mon Sep 17 00:00:00 2001
From: cel 🌸 <cel@bunny.garden>
Date: Sun, 22 Dec 2024 18:58:28 +0000
Subject: implement sink and stream with tokio::spawn

---
 jabber/src/jabber_stream.rs | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

(limited to 'jabber/src/jabber_stream.rs')

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()
-- 
cgit