Constellation, Spacedust, Slingshot, UFOs: atproto crates and services for microcosm
little log and error handling fixup
+4
-8
+4
-8
jetstream/src/lib.rs
+4
-8
jetstream/src/lib.rs
···
354
354
let false = ping_cancelled.is_cancelled() else {
355
355
break;
356
356
};
357
-
match ping_shared_socket_write
357
+
if let Err(error) = ping_shared_socket_write
358
358
.lock()
359
359
.await
360
-
.send(Message::Ping("ping!!!!".as_bytes().to_vec()))
360
+
.send(Message::Ping("ping".as_bytes().to_vec()))
361
361
.await
362
362
{
363
-
Ok(_) => (),
364
-
Err(error) => {
365
-
eprintln!("ping send failed");
366
-
log::error!("Ping failed: {error}");
367
-
break;
368
-
}
363
+
log::error!("Ping failed: {error}");
364
+
break;
369
365
}
370
366
}
371
367
eprintln!("oh this is bad news.");