diff options
| author | 2024-12-04 18:18:37 +0000 | |
|---|---|---|
| committer | 2024-12-04 18:18:37 +0000 | |
| commit | 1b91ff690488b65b552c90bd5392b9a300c8c981 (patch) | |
| tree | 9c290f69b26eba0393d7bbc05ba29c28ea74a26e /jabber/src/jabber_stream | |
| parent | 03764f8cedb3f0a55a61be0f0a59faaa6357a83a (diff) | |
| download | luz-1b91ff690488b65b552c90bd5392b9a300c8c981.tar.gz luz-1b91ff690488b65b552c90bd5392b9a300c8c981.tar.bz2 luz-1b91ff690488b65b552c90bd5392b9a300c8c981.zip  | |
use cargo workspace
Diffstat (limited to '')
| -rw-r--r-- | jabber/src/jabber_stream.rs (renamed from src/jabber_stream.rs) | 19 | 
1 files changed, 9 insertions, 10 deletions
diff --git a/src/jabber_stream.rs b/jabber/src/jabber_stream.rs index 8ee45b5..dd0dcbf 100644 --- a/src/jabber_stream.rs +++ b/jabber/src/jabber_stream.rs @@ -2,26 +2,25 @@ use std::pin::pin;  use std::str::{self, FromStr};  use std::sync::Arc; -use async_recursion::async_recursion;  use futures::StreamExt; +use jid::JID;  use peanuts::element::{FromContent, IntoElement};  use peanuts::{Reader, Writer};  use rsasl::prelude::{Mechname, SASLClient, SASLConfig}; +use stanza::bind::{Bind, BindType, FullJidType, ResourceType}; +use stanza::client::iq::{Iq, IqType, Query}; +use stanza::client::Stanza; +use stanza::sasl::{Auth, Challenge, Mechanisms, Response, ServerResponse}; +use stanza::starttls::{Proceed, StartTls}; +use stanza::stream::{Features, Stream}; +use stanza::XML_VERSION;  use tokio::io::{AsyncRead, AsyncWrite, ReadHalf, WriteHalf};  use tokio_native_tls::native_tls::TlsConnector;  use tracing::{debug, instrument};  use crate::connection::{Tls, Unencrypted};  use crate::error::Error; -use crate::stanza::bind::{Bind, BindType, FullJidType, ResourceType}; -use crate::stanza::client::iq::{Iq, IqType, Query}; -use crate::stanza::client::Stanza; -use crate::stanza::sasl::{Auth, Challenge, Mechanisms, Response, ServerResponse}; -use crate::stanza::starttls::{Proceed, StartTls}; -use crate::stanza::stream::{Feature, Features, Stream}; -use crate::stanza::XML_VERSION; -use crate::JID; -use crate::{Connection, Result}; +use crate::Result;  // open stream (streams started)  pub struct JabberStream<S> {  | 
