File tree Expand file tree Collapse file tree 1 file changed +1
-2
lines changed
Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change @@ -568,7 +568,7 @@ impl<N: Network> Service<N> {
568568 mut expected_next_block : BlockNumber ,
569569 provider : P ,
570570 sender : mpsc:: Sender < Result < RangeInclusive < BlockNumber > , Error > > ,
571- reorg_rewind_depth : u64 ,
571+ _reorg_rewind_depth : u64 ,
572572 ) {
573573 match Self :: get_block_subscription ( & provider) . await {
574574 Ok ( ws_stream) => {
@@ -589,7 +589,6 @@ impl<N: Network> Service<N> {
589589 // TODO: should we send the incoming block range or incoming block num -
590590 // reorg depth? The incoming block should be the
591591 // latest block from the reorg point so no real need
592- // tbd
593592 if sender. send ( Ok ( incoming_block_num..=incoming_block_num) ) . await . is_err ( ) {
594593 warn ! ( "Downstream channel closed, stopping live blocks task (reorg)" ) ;
595594 return ;
You can’t perform that action at this time.
0 commit comments