@Test void shouldNotFetchBlocksBeforeDepositsAreInSync() { blockFetcher.fetch(BigInteger.ZERO, BigInteger.ONE); verifyNoInteractions(eth1Provider); }
public void fetch(final BigInteger fromBlock, final BigInteger toBlock) { synchronized (this) { if (!active) { return; } for (BigInteger block = fromBlock; block.compareTo(toBlock) <= 0; block = block.add(BigInteger.ONE)) { blocksToRequest.add(UInt64.valueOf(block)); } } requestNextBlockIfRequired(); }
Eth1BlockFetcher { public void fetch(final BigInteger fromBlock, final BigInteger toBlock) { synchronized (this) { if (!active) { return; } for (BigInteger block = fromBlock; block.compareTo(toBlock) <= 0; block = block.add(BigInteger.ONE)) { blocksToRequest.add(UInt64.valueOf(block)); } } requestNextBlockIfRequired(); } }
Eth1BlockFetcher { public void fetch(final BigInteger fromBlock, final BigInteger toBlock) { synchronized (this) { if (!active) { return; } for (BigInteger block = fromBlock; block.compareTo(toBlock) <= 0; block = block.add(BigInteger.ONE)) { blocksToRequest.add(UInt64.valueOf(block)); } } requestNextBlockIfRequired(); } Eth1BlockFetcher(
      final Eth1EventsChannel eth1EventsChannel,
      final Eth1Provider eth1Provider,
      final TimeProvider timeProvider,
      final UInt64 cacheDuration); }
Eth1BlockFetcher { public void fetch(final BigInteger fromBlock, final BigInteger toBlock) { synchronized (this) { if (!active) { return; } for (BigInteger block = fromBlock; block.compareTo(toBlock) <= 0; block = block.add(BigInteger.ONE)) { blocksToRequest.add(UInt64.valueOf(block)); } } requestNextBlockIfRequired(); } Eth1BlockFetcher(
      final Eth1EventsChannel eth1EventsChannel,
      final Eth1Provider eth1Provider,
      final TimeProvider timeProvider,
      final UInt64 cacheDuration); synchronized void onInSync(final UInt64 latestCanonicalBlockNumber); void fetch(final BigInteger fromBlock, final BigInteger toBlock); }
Eth1BlockFetcher { public void fetch(final BigInteger fromBlock, final BigInteger toBlock) { synchronized (this) { if (!active) { return; } for (BigInteger block = fromBlock; block.compareTo(toBlock) <= 0; block = block.add(BigInteger.ONE)) { blocksToRequest.add(UInt64.valueOf(block)); } } requestNextBlockIfRequired(); } Eth1BlockFetcher(
      final Eth1EventsChannel eth1EventsChannel,
      final Eth1Provider eth1Provider,
      final TimeProvider timeProvider,
      final UInt64 cacheDuration); synchronized void onInSync(final UInt64 latestCanonicalBlockNumber); void fetch(final BigInteger fromBlock, final BigInteger toBlock);  }