@@ -114,9 +114,7 @@ where
114
114
}
115
115
116
116
fn cancelled ( future : & PyAny ) -> PyResult < bool > {
117
- future. getattr ( "cancelled" ) ?
118
- . call0 ( ) ?
119
- . is_true ( )
117
+ future. getattr ( "cancelled" ) ?. call0 ( ) ?. is_true ( )
120
118
}
121
119
122
120
fn set_result ( py : Python , future : & PyAny , result : PyResult < PyObject > ) -> PyResult < ( ) > {
@@ -222,12 +220,12 @@ where
222
220
Python :: with_gil ( move |py| {
223
221
if cancelled ( future_tx1. as_ref ( py) )
224
222
. map_err ( dump_err ( py) )
225
- . unwrap_or ( false ) {
223
+ . unwrap_or ( false )
224
+ {
226
225
return ;
227
226
}
228
227
229
- let _ = set_result ( py, future_tx1. as_ref ( py) , result)
230
- . map_err ( dump_err ( py) ) ;
228
+ let _ = set_result ( py, future_tx1. as_ref ( py) , result) . map_err ( dump_err ( py) ) ;
231
229
} ) ;
232
230
} )
233
231
. await
@@ -236,7 +234,8 @@ where
236
234
Python :: with_gil ( move |py| {
237
235
if cancelled ( future_tx2. as_ref ( py) )
238
236
. map_err ( dump_err ( py) )
239
- . unwrap_or ( false ) {
237
+ . unwrap_or ( false )
238
+ {
240
239
return ;
241
240
}
242
241
@@ -343,12 +342,12 @@ where
343
342
Python :: with_gil ( move |py| {
344
343
if cancelled ( future_tx1. as_ref ( py) )
345
344
. map_err ( dump_err ( py) )
346
- . unwrap_or ( false ) {
345
+ . unwrap_or ( false )
346
+ {
347
347
return ;
348
348
}
349
349
350
- let _ = set_result ( py, future_tx1. as_ref ( py) , result)
351
- . map_err ( dump_err ( py) ) ;
350
+ let _ = set_result ( py, future_tx1. as_ref ( py) , result) . map_err ( dump_err ( py) ) ;
352
351
} ) ;
353
352
} )
354
353
. await
@@ -357,7 +356,8 @@ where
357
356
Python :: with_gil ( move |py| {
358
357
if cancelled ( future_tx2. as_ref ( py) )
359
358
. map_err ( dump_err ( py) )
360
- . unwrap_or ( false ) {
359
+ . unwrap_or ( false )
360
+ {
361
361
return ;
362
362
}
363
363
0 commit comments