diff options
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() |