@@ -10,11 +10,11 @@ use crate::error::{Error, Result};
10
10
use crate :: types:: ResponseData ;
11
11
use crate :: types:: * ;
12
12
13
- pub ( crate ) fn parse_names < ' a , T : Stream < Item = io:: Result < ResponseData > > + Unpin + Send > (
14
- stream : & ' a mut T ,
13
+ pub ( crate ) fn parse_names < T : Stream < Item = io:: Result < ResponseData > > + Unpin + Send > (
14
+ stream : & mut T ,
15
15
unsolicited : channel:: Sender < UnsolicitedResponse > ,
16
16
command_tag : RequestId ,
17
- ) -> impl Stream < Item = Result < Name > > + ' a + Send + Unpin {
17
+ ) -> impl Stream < Item = Result < Name > > + ' _ + Send + Unpin {
18
18
use futures:: { FutureExt , StreamExt } ;
19
19
20
20
StreamExt :: filter_map (
@@ -56,11 +56,11 @@ fn filter_sync(res: &io::Result<ResponseData>, command_tag: &RequestId) -> bool
56
56
}
57
57
}
58
58
59
- pub ( crate ) fn parse_fetches < ' a , T : Stream < Item = io:: Result < ResponseData > > + Unpin + Send > (
60
- stream : & ' a mut T ,
59
+ pub ( crate ) fn parse_fetches < T : Stream < Item = io:: Result < ResponseData > > + Unpin + Send > (
60
+ stream : & mut T ,
61
61
unsolicited : channel:: Sender < UnsolicitedResponse > ,
62
62
command_tag : RequestId ,
63
- ) -> impl Stream < Item = Result < Fetch > > + ' a + Send + Unpin {
63
+ ) -> impl Stream < Item = Result < Fetch > > + ' _ + Send + Unpin {
64
64
use futures:: { FutureExt , StreamExt } ;
65
65
66
66
StreamExt :: filter_map (
@@ -85,11 +85,11 @@ pub(crate) fn parse_fetches<'a, T: Stream<Item = io::Result<ResponseData>> + Unp
85
85
)
86
86
}
87
87
88
- pub ( crate ) fn parse_expunge < ' a , T : Stream < Item = io:: Result < ResponseData > > + Unpin + Send > (
89
- stream : & ' a mut T ,
88
+ pub ( crate ) fn parse_expunge < T : Stream < Item = io:: Result < ResponseData > > + Unpin + Send > (
89
+ stream : & mut T ,
90
90
unsolicited : channel:: Sender < UnsolicitedResponse > ,
91
91
command_tag : RequestId ,
92
- ) -> impl Stream < Item = Result < u32 > > + ' a + Send {
92
+ ) -> impl Stream < Item = Result < u32 > > + ' _ + Send {
93
93
use futures:: StreamExt ;
94
94
95
95
StreamExt :: filter_map (
@@ -113,8 +113,8 @@ pub(crate) fn parse_expunge<'a, T: Stream<Item = io::Result<ResponseData>> + Unp
113
113
)
114
114
}
115
115
116
- pub ( crate ) async fn parse_capabilities < ' a , T : Stream < Item = io:: Result < ResponseData > > + Unpin > (
117
- stream : & ' a mut T ,
116
+ pub ( crate ) async fn parse_capabilities < T : Stream < Item = io:: Result < ResponseData > > + Unpin > (
117
+ stream : & mut T ,
118
118
unsolicited : channel:: Sender < UnsolicitedResponse > ,
119
119
command_tag : RequestId ,
120
120
) -> Result < Capabilities > {
0 commit comments