@@ -15,8 +15,8 @@ impl<Fut: Future01> Future03 for Compat<Fut, ()> {
15
15
fn poll ( self : PinMut < Self > , cx : & mut task03:: Context ) -> task03:: Poll < Self :: Output > {
16
16
let notify = & WakerToHandle ( cx. waker ( ) ) ;
17
17
18
- executor01:: with_notify ( notify, 0 , move || unsafe {
19
- match PinMut :: get_mut_unchecked ( self ) . inner . poll ( ) {
18
+ executor01:: with_notify ( notify, 0 , move || {
19
+ match unsafe { PinMut :: get_mut_unchecked ( self ) } . inner . poll ( ) {
20
20
Ok ( Async01 :: Ready ( t) ) => task03:: Poll :: Ready ( Ok ( t) ) ,
21
21
Ok ( Async01 :: NotReady ) => task03:: Poll :: Pending ,
22
22
Err ( e) => task03:: Poll :: Ready ( Err ( e) ) ,
@@ -31,8 +31,8 @@ impl<St: Stream01> Stream03 for Compat<St, ()> {
31
31
fn poll_next ( self : PinMut < Self > , cx : & mut task03:: Context ) -> task03:: Poll < Option < Self :: Item > > {
32
32
let notify = & WakerToHandle ( cx. waker ( ) ) ;
33
33
34
- executor01:: with_notify ( notify, 0 , move || unsafe {
35
- match PinMut :: get_mut_unchecked ( self ) . inner . poll ( ) {
34
+ executor01:: with_notify ( notify, 0 , move || {
35
+ match unsafe { PinMut :: get_mut_unchecked ( self ) } . inner . poll ( ) {
36
36
Ok ( Async01 :: Ready ( Some ( t) ) ) => task03:: Poll :: Ready ( Some ( Ok ( t) ) ) ,
37
37
Ok ( Async01 :: Ready ( None ) ) => task03:: Poll :: Ready ( None ) ,
38
38
Ok ( Async01 :: NotReady ) => task03:: Poll :: Pending ,
0 commit comments