build sleep fut earlier (#3)

Author: jordy25519

src/ws_server.rs

@@ -458,8 +458,9 @@ impl WsConnection {
                             } else {
                                 let sender = self.message_tx.clone();
                                 let log_prefix = log_prefix.clone();
+                                let sleep_fut = tokio::time::sleep(send_delay);
                                 tokio::spawn(async move {
-                                    let _ = tokio::time::sleep(send_delay).await;
+                                    let _ = sleep_fut.await;
                                     for new_order_info in updates {
                                         // forward kafka messages to the outbox
                                         if let Err(err) = sender.try_send(new_order_info) {

ts/src/cli.ts

@@ -1,3 +1,4 @@
+// Kafka helper cli
 import { execSync } from 'child_process';
 import { writeFileSync, unlinkSync } from 'fs';
 import { tmpdir } from 'os';