File tree 1 file changed +5
-6
lines changed
1 file changed +5
-6
lines changed Original file line number Diff line number Diff line change 31
31
32
32
use bitcoin:: secp256k1:: PublicKey ;
33
33
34
- use tokio:: net:: { tcp , TcpStream } ;
35
- use tokio:: { io , time} ;
34
+ use tokio:: net:: TcpStream ;
35
+ use tokio:: time;
36
36
use tokio:: sync:: mpsc;
37
- use tokio:: io:: AsyncWrite ;
38
37
39
38
use lightning:: ln:: peer_handler;
40
39
use lightning:: ln:: peer_handler:: SocketDescriptor as LnSocketTrait ;
@@ -231,7 +230,7 @@ impl Connection {
231
230
// readable() is allowed to spuriously wake, so we have to handle
232
231
// WouldBlock here.
233
232
} ,
234
- Err ( e ) => break Disconnect :: PeerDisconnected ,
233
+ Err ( _ ) => break Disconnect :: PeerDisconnected ,
235
234
}
236
235
} ,
237
236
}
@@ -493,10 +492,10 @@ impl peer_handler::SocketDescriptor for SocketDescriptor {
493
492
written_len += res;
494
493
if written_len == data. len ( ) { return written_len; }
495
494
} ,
496
- Err ( e ) => return written_len,
495
+ Err ( _ ) => return written_len,
497
496
}
498
497
} ,
499
- task:: Poll :: Ready ( Err ( e ) ) => return written_len,
498
+ task:: Poll :: Ready ( Err ( _ ) ) => return written_len,
500
499
task:: Poll :: Pending => {
501
500
// We're queued up for a write event now, but we need to make sure we also
502
501
// pause read given we're now waiting on the remote end to ACK (and in
You can’t perform that action at this time.
0 commit comments