commit 0e050a11aa9131b003ab59286884e4c6df82017a · nekomimi.pet/microcosm-rs

+16 -16
README.md
···

       9
       9
        
       

     

       10
       10
        
       ```rust

     

       11
       11
        
       let config = JetstreamConfig {

     

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

     

       13
       13
       -
       compression: JetstreamCompression::Zstd,

     

       14
       14
       -
       ..Default::default ()

     

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

     

       13
       13
       +
           compression: JetstreamCompression::Zstd,

     

       14
       14
       +
           ..Default::default()

     

       15
       15
        
       };

     

       16
       16
        
       

     

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

     

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

     

       19
       19
        
       

     

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

     

       21
       21
       -
       if let Commit(commit) = event {

     

       22
       22
       -
       match commit {

     

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

     

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

     

       25
       25
       -
       }

     

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

     

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

     

       28
       28
       -
       }

     

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

     

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

     

       31
       31
       -
       }

     

       32
       32
       -
       }

     

       33
       33
       -
       }

     

       21
       21
       +
           if let Commit(commit) = event {

     

       22
       22
       +
               match commit {

     

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

     

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

     

       25
       25
       +
                   }

     

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

     

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

     

       28
       28
       +
                   }

     

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

     

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

     

       31
       31
       +
                   }

     

       32
       32
       +
               }

     

       33
       33
       +
           }

     

       34
       34
        
       }

     

       35
       35
        
       ```

     

       36
       36