@@ -15,14 +15,14 @@ use std::io::{Write, BufReader};
15
15
use std:: net:: TcpStream ;
16
16
use std:: ops:: Deref ;
17
17
18
- use auth:: Authenticator ;
19
- use auth:: { PlainAuth , ScramAuth , AnonAuth } ;
20
- use non_stanzas:: { AuthStart , AuthResponse , DefinedCondition , StreamStart , StreamEnd } ;
21
- use non_stanzas:: { StreamError , StartTls } ;
22
- use read_str:: ReadString ;
23
- use stanzas:: { AStanza , Stanza , IqType } ;
24
- use xmpp_send:: XmppSend ;
25
- use xmpp_socket:: XmppSocket ;
18
+ use crate :: auth:: Authenticator ;
19
+ use crate :: auth:: { PlainAuth , ScramAuth , AnonAuth } ;
20
+ use crate :: non_stanzas:: { AuthStart , AuthResponse , DefinedCondition , StreamStart , StreamEnd } ;
21
+ use crate :: non_stanzas:: { StreamError , StartTls } ;
22
+ use crate :: read_str:: ReadString ;
23
+ use crate :: stanzas:: { AStanza , Stanza , IqType } ;
24
+ use crate :: xmpp_send:: XmppSend ;
25
+ use crate :: xmpp_socket:: XmppSocket ;
26
26
27
27
mod auth;
28
28
mod non_stanzas;
@@ -112,9 +112,9 @@ impl XmppStream {
112
112
pub fn connect ( & mut self ) -> io:: Result < ( ) > {
113
113
let stream = {
114
114
let address = & self . handler . domain [ ..] ;
115
- try! ( TcpStream :: connect ( & ( address, 5222 ) ) )
115
+ TcpStream :: connect ( & ( address, 5222 ) ) ?
116
116
} ;
117
- let stream_read = try! ( stream. try_clone ( ) ) ;
117
+ let stream_read = stream. try_clone ( ) ? ;
118
118
119
119
self . handler . socket = XmppSocket :: Tcp ( BufReader :: new ( stream_read) , stream) ;
120
120
self . handler . start_stream ( )
@@ -226,7 +226,7 @@ impl XmppHandler {
226
226
fn start_stream ( & mut self ) -> io:: Result < ( ) > {
227
227
let stream_start = StreamStart { to : & self . domain } ;
228
228
println ! ( "Out: {}" , stream_start) ;
229
- try! ( stream_start. xmpp_send ( & mut self . socket ) ) ;
229
+ stream_start. xmpp_send ( & mut self . socket ) ? ;
230
230
self . socket . flush ( )
231
231
}
232
232
@@ -241,7 +241,7 @@ impl XmppHandler {
241
241
242
242
fn send < T : XmppSend > ( & mut self , data : T ) -> io:: Result < ( ) > {
243
243
println ! ( "Out: {}" , data) ;
244
- try! ( data. xmpp_send ( & mut self . socket ) ) ;
244
+ data. xmpp_send ( & mut self . socket ) ? ;
245
245
self . socket . flush ( )
246
246
}
247
247
@@ -275,7 +275,7 @@ impl XmppHandler {
275
275
276
276
fn handle_starttls ( & mut self , starttls : xml:: Element ) -> io:: Result < ( ) > {
277
277
if starttls. name == "proceed" {
278
- try! ( self . socket . starttls ( & self . domain ) ) ;
278
+ self . socket . starttls ( & self . domain ) ? ;
279
279
return self . start_stream ( ) ;
280
280
}
281
281
Ok ( ( ) )
0 commit comments