File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
src/client/client_request Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -13,7 +13,7 @@ pub struct ReadEventsRequest<'a> {
13
13
pub options : Option < ReadEventsRequestOptions < ' a > > ,
14
14
}
15
15
16
- impl < ' a > ClientRequest for ReadEventsRequest < ' a > {
16
+ impl ClientRequest for ReadEventsRequest < ' _ > {
17
17
const URL_PATH : & ' static str = "/api/v1/read-events" ;
18
18
const METHOD : Method = Method :: POST ;
19
19
@@ -22,7 +22,7 @@ impl<'a> ClientRequest for ReadEventsRequest<'a> {
22
22
}
23
23
}
24
24
25
- impl < ' a > StreamingRequest for ReadEventsRequest < ' a > {
25
+ impl StreamingRequest for ReadEventsRequest < ' _ > {
26
26
type ItemType = Event ;
27
27
28
28
fn build_stream (
@@ -32,14 +32,14 @@ impl<'a> StreamingRequest for ReadEventsRequest<'a> {
32
32
#[ serde( tag = "type" , content = "payload" , rename_all = "camelCase" ) ]
33
33
enum LineItem {
34
34
Error { error : String } ,
35
- Event ( Event ) ,
35
+ Event ( Box < Event > ) ,
36
36
}
37
37
38
38
impl From < LineItem > for Result < Event , ClientError > {
39
39
fn from ( item : LineItem ) -> Self {
40
40
match item {
41
41
LineItem :: Error { error } => Err ( ClientError :: DBError ( error) ) ,
42
- LineItem :: Event ( event_type) => Ok ( event_type) ,
42
+ LineItem :: Event ( event_type) => Ok ( * event_type) ,
43
43
}
44
44
}
45
45
}
You can’t perform that action at this time.
0 commit comments