File tree Expand file tree Collapse file tree 1 file changed +4
-7
lines changed Expand file tree Collapse file tree 1 file changed +4
-7
lines changed Original file line number Diff line number Diff line change @@ -20,7 +20,7 @@ Server setup instructions can be found here [EventStoreDB Docs], follow the dock
20
20
# Example
21
21
22
22
``` rust
23
- use eventstore :: { EventData , Client , ReadResult };
23
+ use eventstore :: { All , Client , EventData , ReadResult };
24
24
use futures :: stream :: TryStreamExt ;
25
25
use serde :: {Serialize , Deserialize };
26
26
@@ -45,21 +45,18 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
45
45
let evt = EventData :: json (" language-poll" , & payload )? ;
46
46
47
47
let _ = client
48
- . write_events (" language-stream" )
49
- . send_event (evt )
48
+ . append_to_stream (" language-stream" , & Default :: default (), evt )
50
49
. await ? ;
51
50
52
51
let result = client
53
- . read_stream (" language-stream" )
54
- . start_from_beginning ()
55
- . read_through ()
52
+ . read_stream (" language-stream" , & Default :: default (), All )
56
53
. await ? ;
57
54
58
55
if let ReadResult :: Ok (mut stream ) = result {
59
56
while let Some (event ) = stream . try_next (). await ? {
60
57
let event = event . get_original_event ()
61
58
. as_json :: <Foo >()? ;
62
-
59
+
63
60
// Do something productive with the result.
64
61
println! (" {:?}" , event );
65
62
}
You can’t perform that action at this time.
0 commit comments