rustfmt
This commit is contained in:
parent
36ac6c1e5e
commit
0660e25bdb
|
@ -31,8 +31,8 @@ async fn main() {
|
||||||
identify.token = token;
|
identify.token = token;
|
||||||
|
|
||||||
// Send off the event
|
// Send off the event
|
||||||
gateway.send_identify(identify).await;
|
gateway.send_identify(identify).await;
|
||||||
|
|
||||||
// Do something on the main thread so we don't quit
|
// Do something on the main thread so we don't quit
|
||||||
loop {
|
loop {
|
||||||
sleep(Duration::from_secs(3600)).await;
|
sleep(Duration::from_secs(3600)).await;
|
||||||
|
|
|
@ -71,7 +71,7 @@ impl HeartbeatHandler {
|
||||||
let mut last_heartbeat_timestamp: Instant = Instant::now();
|
let mut last_heartbeat_timestamp: Instant = Instant::now();
|
||||||
let mut last_heartbeat_acknowledged = true;
|
let mut last_heartbeat_acknowledged = true;
|
||||||
let mut last_seq_number: Option<u64> = None;
|
let mut last_seq_number: Option<u64> = None;
|
||||||
|
|
||||||
loop {
|
loop {
|
||||||
if kill_receive.try_recv().is_ok() {
|
if kill_receive.try_recv().is_ok() {
|
||||||
trace!("GW: Closing heartbeat task");
|
trace!("GW: Closing heartbeat task");
|
||||||
|
|
Loading…
Reference in New Issue