Skip to content

Commit

Permalink
chore(papyrus_p2p_sync): add block data receiver to p2psyncclient
Browse files Browse the repository at this point in the history
  • Loading branch information
eitanm-starkware committed Dec 10, 2024
1 parent f92d97a commit dc1c438
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion crates/papyrus_p2p_sync/src/client/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@ use std::time::Duration;

use class::ClassStreamBuilder;
use futures::channel::mpsc::SendError;
use futures::stream::BoxStream;
use futures::Stream;
use header::HeaderStreamBuilder;
use papyrus_common::pending_classes::ApiContractClass;
Expand All @@ -41,7 +42,7 @@ use starknet_api::block::BlockNumber;
use starknet_api::core::ClassHash;
use starknet_api::transaction::FullTransaction;
use state_diff::StateDiffStreamBuilder;
use stream_builder::{DataStreamBuilder, DataStreamResult};
use stream_builder::{BlockData, DataStreamBuilder, DataStreamResult};
use tokio_stream::StreamExt;
use tracing::instrument;
use transaction::TransactionStreamFactory;
Expand Down Expand Up @@ -226,6 +227,7 @@ pub struct P2PSyncClient {
storage_reader: StorageReader,
storage_writer: StorageWriter,
p2p_sync_channels: P2PSyncClientChannels,
block_data_receiver: BoxStream<BlockData>,
}

impl P2PSyncClient {
Expand Down

0 comments on commit dc1c438

Please sign in to comment.