From 95da45f5973eb61cd900b6a1c7cb5bb4031dfb54 Mon Sep 17 00:00:00 2001 From: Christian Kamm Date: Mon, 8 Nov 2021 11:44:37 +0100 Subject: [PATCH] Remove stale TODO comments --- accountsdb-plugin-grpc/src/accountsdb_plugin_grpc.rs | 1 - accountsdb-plugin-grpc/src/test_server.rs | 1 - 2 files changed, 2 deletions(-) diff --git a/accountsdb-plugin-grpc/src/accountsdb_plugin_grpc.rs b/accountsdb-plugin-grpc/src/accountsdb_plugin_grpc.rs index a7420d1..7311d4c 100644 --- a/accountsdb-plugin-grpc/src/accountsdb_plugin_grpc.rs +++ b/accountsdb-plugin-grpc/src/accountsdb_plugin_grpc.rs @@ -227,7 +227,6 @@ impl AccountsDbPlugin for Plugin { slot, ); - // TODO: send the update to all connected streams data.broadcast(UpdateOneof::AccountWrite(AccountWrite { slot, is_startup, diff --git a/accountsdb-plugin-grpc/src/test_server.rs b/accountsdb-plugin-grpc/src/test_server.rs index 095cc4a..4c852b2 100644 --- a/accountsdb-plugin-grpc/src/test_server.rs +++ b/accountsdb-plugin-grpc/src/test_server.rs @@ -40,7 +40,6 @@ pub mod accountsdb_service { let mut broadcast_rx = self.sender.subscribe(); tokio::spawn(async move { loop { - // TODO: Deal with lag! maybe just close if RecvError::Lagged happens let msg = broadcast_rx.recv().await.unwrap(); tx.send(Ok(msg)).await.unwrap(); }