pub async fn run<P, ChT, CaT, DbT>(
client: &mut CompactTxStreamerClient<ChT>,
params: &P,
db_cache: &CaT,
db_data: &mut DbT,
batch_size: u32,
) -> Result<(), Error<CaT::Error, <DbT as WalletRead>::Error, <DbT as WalletCommitmentTrees>::Error>>where
P: Parameters + Send + 'static,
ChT: GrpcService<Body>,
ChT::Error: Into<StdError>,
ChT::ResponseBody: Body<Data = Bytes> + Send + 'static,
<ChT::ResponseBody as Body>::Error: Into<StdError> + Send,
CaT: BlockCache,
CaT::Error: Error + Send + Sync + 'static,
DbT: WalletWrite + WalletCommitmentTrees,
DbT::AccountId: ConditionallySelectable + Default + Send + 'static,
<DbT as WalletRead>::Error: Error + Send + Sync + 'static,
<DbT as WalletCommitmentTrees>::Error: Error + Send + Sync + 'static,Available on crate feature
sync only.Expand description
Scans the chain until the wallet is up-to-date.