···

       
9
       
 
       


     

       
10
       
 
       
```rust

     

       
11
       
 
       
let config = JetstreamConfig {

     

       
12
       
-
       
    endpoint: DefaultJetstreamEndpoints::USEastOne.into(),

     

       
13
       
-
       
    compression: JetstreamCompression::Zstd,

     

       
14
       
-
       
    ..Default::default()

     

       
15
       
 
       
};

     

       
16
       
 
       


     

       
17
       
 
       
let jetstream = JetstreamConnector::new(config).unwrap();

     

       
18
       
-
       
let (receiver, _) = jetstream.connect().await.unwrap();

     

       
19
       
 
       


     

       
20
       
 
       
while let Ok(event) = receiver.recv_async().await {

     

       
21
       
-
       
    if let Commit(commit) = event {

     

       
22
       
-
       
        match commit {

     

       
23
       
-
       
            CommitEvent::Create { info, commit } => {

     

       
24
       
-
       
                println!("Received create event: {:#?}", info);

     

       
25
       
-
       
            }

     

       
26
       
-
       
            CommitEvent::Update { info, commit } => {

     

       
27
       
-
       
                println!("Received update event: {:#?}", info);

     

       
28
       
-
       
            }

     

       
29
       
-
       
            CommitEvent::Delete { info, commit } => {

     

       
30
       
-
       
                println!("Received delete event: {:#?}", info);

     

       
31
       
-
       
            }

     

       
32
       
-
       
        }

     

       
33
       
-
       
    }

     

       
34
       
 
       
}

     

       
35
       
 
       
```

     

       
36
       
 
       


     

···

       
9
       
 
       


     

       
10
       
 
       
```rust

     

       
11
       
 
       
let config = JetstreamConfig {

     

       
12
       
+
       
endpoint: DefaultJetstreamEndpoints::USEastOne.into(),

     

       
13
       
+
       
compression: JetstreamCompression::Zstd,

     

       
14
       
+
       
..Default::default ()

     

       
15
       
 
       
};

     

       
16
       
 
       


     

       
17
       
 
       
let jetstream = JetstreamConnector::new(config).unwrap();

     

       
18
       
+
       
let receiver = jetstream.connect().await?;

     

       
19
       
 
       


     

       
20
       
 
       
while let Ok(event) = receiver.recv_async().await {

     

       
21
       
+
       
if let Commit(commit) = event {

     

       
22
       
+
       
match commit {

     

       
23
       
+
       
CommitEvent::Create { info, commit } => {

     

       
24
       
+
       
println ! ("Received create event: {:#?}", info);

     

       
25
       
+
       
}

     

       
26
       
+
       
CommitEvent::Update { info, commit } => {

     

       
27
       
+
       
println ! ("Received update event: {:#?}", info);

     

       
28
       
+
       
}

     

       
29
       
+
       
CommitEvent::Delete { info, commit } => {

     

       
30
       
+
       
println ! ("Received delete event: {:#?}", info);

     

       
31
       
+
       
}

     

       
32
       
+
       
}

     

       
33
       
+
       
}

     

       
34
       
 
       
}

     

       
35
       
 
       
```

     

       
36