File tree 3 files changed +4
-4
lines changed
3 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -666,7 +666,7 @@ impl Connection {
666
666
this : & ' a mut Connection ,
667
667
}
668
668
669
- impl < ' a > fmt:: Write for Writer < ' a > {
669
+ impl fmt:: Write for Writer < ' _ > {
670
670
fn write_str ( & mut self , s : & str ) -> fmt:: Result {
671
671
self . this . write_buf_len += s. len ( ) ;
672
672
self . this . flattened_writes . write_str ( s)
Original file line number Diff line number Diff line change @@ -330,7 +330,7 @@ pub struct Batch {
330
330
terminated : bool ,
331
331
}
332
332
333
- impl < ' a > Batch {
333
+ impl Batch {
334
334
async fn batch ( batch : BatchConfig , consumer : & Consumer < Config > ) -> Result < Batch , BatchError > {
335
335
let inbox = Subject :: from ( consumer. context . client . new_inbox ( ) ) ;
336
336
let subscription = consumer. context . client . subscribe ( inbox. clone ( ) ) . await ?;
Original file line number Diff line number Diff line change @@ -475,7 +475,7 @@ impl ConnectionHandler {
475
475
Closed ,
476
476
}
477
477
478
- impl < ' a > ProcessFut < ' a > {
478
+ impl ProcessFut < ' _ > {
479
479
const RECV_CHUNK_SIZE : usize = 16 ;
480
480
481
481
#[ cold]
@@ -497,7 +497,7 @@ impl ConnectionHandler {
497
497
}
498
498
}
499
499
500
- impl < ' a > Future for ProcessFut < ' a > {
500
+ impl Future for ProcessFut < ' _ > {
501
501
type Output = ExitReason ;
502
502
503
503
/// Drives the connection forward.
You can’t perform that action at this time.
0 commit comments