@@ -5,10 +5,10 @@ use futures_channel::mpsc;
5
5
use futures_core:: future:: BoxFuture ;
6
6
use futures_core:: stream:: { BoxStream , Stream } ;
7
7
use futures_util:: { FutureExt , StreamExt , TryFutureExt , TryStreamExt } ;
8
+ use sqlx_core:: Either ;
8
9
use sqlx_core:: acquire:: Acquire ;
9
10
use sqlx_core:: sql_str:: { AssertSqlSafe , SqlStr } ;
10
11
use sqlx_core:: transaction:: Transaction ;
11
- use sqlx_core:: Either ;
12
12
use tracing:: Instrument ;
13
13
14
14
use crate :: describe:: Describe ;
@@ -211,7 +211,7 @@ impl PgListener {
211
211
212
212
crate :: rt:: sleep ( std:: time:: Duration :: from_millis ( backoff_ms) ) . await ;
213
213
continue ;
214
- } ,
214
+ }
215
215
Err ( other) => return Err ( other) ,
216
216
}
217
217
}
@@ -282,7 +282,7 @@ impl PgListener {
282
282
/// [`eager_reconnect`]: PgListener::eager_reconnect
283
283
pub async fn try_recv ( & mut self ) -> Result < Option < PgNotification > , Error > {
284
284
match self . recv_without_recovery ( ) . await {
285
- Ok ( notification) => return Ok ( Some ( notification) ) ,
285
+ Ok ( notification) => Ok ( Some ( notification) ) ,
286
286
287
287
// The connection is dead, ensure that it is dropped,
288
288
// update self state, and loop to try again.
@@ -298,9 +298,9 @@ impl PgListener {
298
298
}
299
299
300
300
// lost connection
301
- return Ok ( None ) ;
302
- } ,
303
- Err ( e) => return Err ( e) ,
301
+ Ok ( None )
302
+ }
303
+ Err ( e) => Err ( e) ,
304
304
}
305
305
}
306
306
0 commit comments