diff --git a/chains/ethereum/server/src/block_stream.rs b/chains/ethereum/server/src/block_stream.rs
index 0e1eab39..48972ce1 100644
--- a/chains/ethereum/server/src/block_stream.rs
+++ b/chains/ethereum/server/src/block_stream.rs
@@ -31,9 +31,6 @@ where
     RPC::SubscriptionError: Send + Sync,
 {
     stream: Option<EthereumEventStream<P, RPC>>,
-    // block_tree: VecDeque<TinyVec<[BlockRef; 3]>>,
-    // head: Option<BlockRef>,
-    // best_block: Option<BlockRef>,
     state: State,
 }
 
@@ -54,9 +51,6 @@ where
     pub fn new(provider: P, client: RPC, state: State) -> Self {
         Self {
             stream: Some(EthereumEventStream::new(client, provider)),
-            // block_tree: VecDeque::with_capacity(2048),
-            // head: None,
-            // best_block: None,
             state,
         }
     }
diff --git a/rosetta-utils/src/futures/throttle.rs b/rosetta-utils/src/futures/throttle.rs
index db96c28c..839fda9e 100644
--- a/rosetta-utils/src/futures/throttle.rs
+++ b/rosetta-utils/src/futures/throttle.rs
@@ -18,11 +18,6 @@ impl<F: FutureFactory + 'static> Throttle<F> where F::Output: Clone {
     pub fn new(callback: F, delay: Duration) -> Self {
         Self { callback, delay, state: State::Idle }
     }
-
-    // pub fn flush(&mut self) {
-    //     let future = self.callback.new_future();
-    //     self.future = Some(self.callback.new_future().shared());
-    // }
 }
 
 impl <'a, F: FutureFactory + 'a> Future for Throttle<F> {
@@ -82,6 +77,7 @@ impl <'a, F: FutureFactory + 'a> Future for Throttle<F> {
                 }
             },
         };
+        
     }
 }