commit 175a71a00c228dc61a9652f34e81d02abf002f6e · nekomimi.pet/microcosm-rs

+13 -6

constellation/src/consumer/jetstream.rs

···

       226
        
                                   println!("jetstream closed the websocket cleanly.");

     

       227
        
                                   break;

     

       228
        
                               }

     

       229
       -
                               r => eprintln!("jetstream: close result after error: {r:?}"),

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       230
        
                           }

     

       231
       -
                           counter!("jetstream_read_fail", "url" => stream.clone(), "reason" => "read error")

     

       232
       -
                               .increment(1);

     

       233
       -
                           // if we didn't immediately get ConnectionClosed, we should keep polling read

     

       234
       -
                           // until we get it.

     

       235
       -
                           continue;

     

       236
        
                       }

     

       237
        
                   };

     

       238

···

       226
        
                                   println!("jetstream closed the websocket cleanly.");

     

       227
        
                                   break;

     

       228
        
                               }

     

       229
       +
                               Err(_) => {

     

       230
       +
                                   counter!("jetstream_read_fail", "url" => stream.clone(), "reason" => "dirty close").increment(1);

     

       231
       +
                                   println!("jetstream failed to close the websocket cleanly.");

     

       232
       +
                                   break;

     

       233
       +
                               }

     

       234
       +
                               Ok(r) => {

     

       235
       +
                                   eprintln!("jetstream: close result after error: {r:?}");

     

       236
       +
                                   counter!("jetstream_read_fail", "url" => stream.clone(), "reason" => "read error")

     

       237
       +
                                       .increment(1);

     

       238
       +
                                   // if we didn't immediately get ConnectionClosed, we should keep polling read

     

       239
       +
                                   // until we get it.

     

       240
       +
                                   continue;

     

       241
       +
                               }

     

       242
        
                           }

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       243
        
                       }

     

       244
        
                   };

     

       245