File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -211,11 +211,11 @@ 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 }
218-
218+
219219 // if 5 retries later still got IO error, return the last one and stop
220220 Err ( last_err. unwrap ( ) )
221221 }
@@ -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
You can’t perform that action at this time.
0 commit comments