@@ -5,10 +5,10 @@ use futures_channel::mpsc;
55use futures_core:: future:: BoxFuture ;
66use futures_core:: stream:: { BoxStream , Stream } ;
77use futures_util:: { FutureExt , StreamExt , TryFutureExt , TryStreamExt } ;
8+ use sqlx_core:: Either ;
89use sqlx_core:: acquire:: Acquire ;
910use sqlx_core:: sql_str:: { AssertSqlSafe , SqlStr } ;
1011use sqlx_core:: transaction:: Transaction ;
11- use sqlx_core:: Either ;
1212use tracing:: Instrument ;
1313
1414use crate :: describe:: Describe ;
@@ -211,7 +211,7 @@ impl PgListener {
211211
212212 crate :: rt:: sleep ( std:: time:: Duration :: from_millis ( backoff_ms) ) . await ;
213213 continue ;
214- } ,
214+ }
215215 Err ( other) => return Err ( other) ,
216216 }
217217 }
@@ -282,7 +282,7 @@ impl PgListener {
282282 /// [`eager_reconnect`]: PgListener::eager_reconnect
283283 pub async fn try_recv ( & mut self ) -> Result < Option < PgNotification > , Error > {
284284 match self . recv_without_recovery ( ) . await {
285- Ok ( notification) => return Ok ( Some ( notification) ) ,
285+ Ok ( notification) => Ok ( Some ( notification) ) ,
286286
287287 // The connection is dead, ensure that it is dropped,
288288 // update self state, and loop to try again.
@@ -298,9 +298,9 @@ impl PgListener {
298298 }
299299
300300 // lost connection
301- return Ok ( None ) ;
302- } ,
303- Err ( e) => return Err ( e) ,
301+ Ok ( None )
302+ }
303+ Err ( e) => Err ( e) ,
304304 }
305305 }
306306
0 commit comments