From b859cd7f78495da90b947febabefdff82c02deb9 Mon Sep 17 00:00:00 2001 From: cel 🌸 Date: Tue, 25 Feb 2025 19:50:15 +0000 Subject: cleanup jabber crate --- jabber/src/jabber_stream.rs | 12 ++---------- 1 file changed, 2 insertions(+), 10 deletions(-) (limited to 'jabber/src/jabber_stream.rs') diff --git a/jabber/src/jabber_stream.rs b/jabber/src/jabber_stream.rs index c38f930..6fa92b5 100644 --- a/jabber/src/jabber_stream.rs +++ b/jabber/src/jabber_stream.rs @@ -1,10 +1,8 @@ -use std::pin::pin; use std::str::{self, FromStr}; use std::sync::Arc; -use futures::{sink, stream, StreamExt}; use jid::JID; -use peanuts::element::{FromContent, IntoElement}; +use peanuts::element::IntoElement; use peanuts::{Reader, Writer}; use rsasl::prelude::{Mechname, SASLClient, SASLConfig}; use stanza::bind::{Bind, BindType, FullJidType, ResourceType}; @@ -141,7 +139,7 @@ where let mut session = sasl.start_suggested(&offered_mechs)?; let selected_mechanism = session.get_mechname().as_str().to_owned(); debug!("selected mech: {:?}", selected_mechanism); - let mut data: Option> = None; + let mut data: Option>; if !session.are_we_first() { // if not first mention the mechanism then get challenge data @@ -409,13 +407,7 @@ impl std::fmt::Debug for JabberStream { #[cfg(test)] mod tests { - use std::time::Duration; - - use super::*; - use crate::connection::Connection; - use futures::sink; use test_log::test; - use tokio::time::sleep; #[test(tokio::test)] async fn start_stream() { -- cgit