Remove more unused code

Analog-Labs · Sep 2, 2024 · a7219d2 · a7219d2
1 parent 8c90987
commit a7219d2
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 11 deletions.
diff --git 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
@@ -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> {
                 }
             },
         };
+
     }
 }