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(); }