Skip to content

Commit c58deac

Browse files
authored
fix: chaintipreached streamed only in sync mode (#117)
1 parent 3665c27 commit c58deac

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/block_range_scanner.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -546,6 +546,8 @@ impl<N: Network> Service<N> {
546546
return Err(BlockRangeScannerError::HistoricalSyncError(e.to_string()));
547547
}
548548

549+
self.send_to_subscriber(ScannerMessage::Status(ScannerStatus::ChainTipReached)).await;
550+
549551
let Some(sender) = self.subscriber.clone() else {
550552
return Err(BlockRangeScannerError::ServiceShutdown);
551553
};
@@ -601,8 +603,6 @@ impl<N: Network> Service<N> {
601603

602604
info!(batch_count = batch_count, "Historical sync completed");
603605

604-
self.send_to_subscriber(ScannerMessage::Status(ScannerStatus::ChainTipReached)).await;
605-
606606
Ok(())
607607
}
608608

0 commit comments

Comments
 (0)