use send_to_client more

Author: Centril

crates/core/src/subscription/module_subscription_manager.rs

@@ -1475,15 +1475,13 @@ impl SendWorker {
                     tx_offset,
                     message,
                 } => match tx_offset {
-                    None => {
-                        let _ = recipient.send_message(None, message);
-                    }
+                    None => send_to_client(&recipient, None, message),
                     Some(tx_offset) => {
                         let Ok(tx_offset) = tx_offset.await else {
                             tracing::error!("tx offset sender dropped, exiting send worker");
                             return;
                         };
-                        let _ = recipient.send_message(Some(tx_offset), message);
+                        send_to_client(&recipient, Some(tx_offset), message);
                     }
                 },
                 SendWorkerMessage::RemoveClient(client_id) => {

crates/datastore/src/locking_tx_datastore/mut_tx.rs

@@ -1693,7 +1693,7 @@ impl MutTxId {
         //
         // Note that technically the tx could have run against an empty database,
         // in which case we'd wrongly return zero (a non-existent transaction).
-        // This doesn not happen in practice, however, as [RelationalDB::set_initialized]
+        // This doesn't happen in practice, however, as [RelationalDB::set_initialized]
         // creates a transaction.
         let tx_offset = if tx_offset == self.committed_state_write_lock.next_tx_offset {
             tx_offset.saturating_sub(1)