mirror of
https://github.com/hl-archive-node/nanoreth.git
synced 2025-12-06 10:59:55 +00:00
chore(engine, state root task): remove unused StdReceiverStream struct (#12953)
This commit is contained in:
@ -16,7 +16,7 @@ use revm_primitives::{keccak256, EvmState, B256};
|
||||
use std::{
|
||||
collections::BTreeMap,
|
||||
sync::{
|
||||
mpsc::{self, Receiver, RecvError, Sender},
|
||||
mpsc::{self, Receiver, Sender},
|
||||
Arc,
|
||||
},
|
||||
time::{Duration, Instant},
|
||||
@ -59,23 +59,6 @@ pub(crate) struct StateRootConfig<Factory> {
|
||||
pub input: Arc<TrieInput>,
|
||||
}
|
||||
|
||||
/// Wrapper for std channel receiver to maintain compatibility with `UnboundedReceiverStream`
|
||||
#[derive(Debug)]
|
||||
pub(crate) struct StdReceiverStream {
|
||||
rx: Receiver<EvmState>,
|
||||
}
|
||||
|
||||
#[allow(dead_code)]
|
||||
impl StdReceiverStream {
|
||||
pub(crate) const fn new(rx: Receiver<EvmState>) -> Self {
|
||||
Self { rx }
|
||||
}
|
||||
|
||||
pub(crate) fn recv(&self) -> Result<EvmState, RecvError> {
|
||||
self.rx.recv()
|
||||
}
|
||||
}
|
||||
|
||||
/// Messages used internally by the state root task
|
||||
#[derive(Debug)]
|
||||
#[allow(dead_code)]
|
||||
|
||||
Reference in New Issue
Block a user