···

       
174
       
174
       
 
       
                    println!("jetstream: closing the connection: {f:?}");

     

       
175
       
175
       
 
       
                    continue;

     

       
176
       
176
       
 
       
                }

     

       
177
       
177
       
+
       
                Ok(Message::Ping(bytes)) => {

     

       
178
       
178
       
+
       
                    let _ = socket.send(Message::Pong(bytes));

     

       
179
       
179
       
+
       
                    continue;

     

       
180
       
180
       
+
       
                }

     

       
177
       
181
       
 
       
                Ok(m) => {

     

       
178
       
182
       
 
       
                    counter!("jetstream_read_fail", "url" => stream.clone(), "reason" => "unexpected message", "message" => format!("{m:?}")).increment(1);

     

       
179
       
183
       
 
       
                    eprintln!("jetstream: unexpected from read (ignoring): {m:?}");