File tree Expand file tree Collapse file tree 5 files changed +8
-8
lines changed Expand file tree Collapse file tree 5 files changed +8
-8
lines changed Original file line number Diff line number Diff line change @@ -44,5 +44,5 @@ async fn open_tcp_socket(
44
44
}
45
45
46
46
// Start connecting. If an attempt succeeds, cancel all others attempts.
47
- Ok ( futures. race_ok ( ) . await ? )
47
+ futures. race_ok ( ) . await
48
48
}
Original file line number Diff line number Diff line change 76
76
77
77
async fn progress ( self : Pin < & mut Self > ) -> super :: ConsumerState {
78
78
let mut this = self . project ( ) ;
79
- while let Some ( _ ) = this. group . next ( ) . await { }
79
+ while ( this. group . next ( ) . await ) . is_some ( ) { }
80
80
ConsumerState :: Empty
81
81
}
82
82
85
85
// 4. We will no longer receive any additional futures from the
86
86
// underlying stream; wait until all the futures in the group have
87
87
// resolved.
88
- while let Some ( _ ) = this. group . next ( ) . await { }
88
+ while ( this. group . next ( ) . await ) . is_some ( ) { }
89
89
}
90
90
}
91
91
Original file line number Diff line number Diff line change @@ -338,7 +338,7 @@ mod test {
338
338
use futures_lite:: future:: pending;
339
339
340
340
thread_local ! {
341
- static NOT_LEAKING : RefCell <bool > = RefCell :: new( false ) ;
341
+ static NOT_LEAKING : RefCell <bool > = const { RefCell :: new( false ) } ;
342
342
} ;
343
343
344
344
struct FlipFlagAtDrop ;
Original file line number Diff line number Diff line change @@ -382,7 +382,7 @@ mod test {
382
382
use futures_lite:: future:: pending;
383
383
384
384
thread_local ! {
385
- static NOT_LEAKING : RefCell <bool > = RefCell :: new( false ) ;
385
+ static NOT_LEAKING : RefCell <bool > = const { RefCell :: new( false ) } ;
386
386
} ;
387
387
388
388
struct FlipFlagAtDrop ;
Original file line number Diff line number Diff line change @@ -161,8 +161,8 @@ pub struct PrivateMarker;
161
161
#[ macro_export]
162
162
macro_rules! private_impl {
163
163
( ) => {
164
- fn __futures_concurrency_private__( & self ) -> crate :: private:: PrivateMarker {
165
- crate :: private:: PrivateMarker
164
+ fn __futures_concurrency_private__( & self ) -> $ crate:: private:: PrivateMarker {
165
+ $ crate:: private:: PrivateMarker
166
166
}
167
167
} ;
168
168
}
@@ -174,6 +174,6 @@ macro_rules! private_decl {
174
174
/// This trait is private; this method exists to make it
175
175
/// impossible to implement outside the crate.
176
176
#[ doc( hidden) ]
177
- fn __futures_concurrency_private__( & self ) -> crate :: private:: PrivateMarker ;
177
+ fn __futures_concurrency_private__( & self ) -> $ crate:: private:: PrivateMarker ;
178
178
} ;
179
179
}
You can’t perform that action at this time.
0 commit comments