@Test public void onBlockProductionDue_shouldActImmediatelyIfDutiesLoaded() { scheduledDutiesFuture.complete(scheduledDuties); duties.onBlockProductionDue(ONE); verify(scheduledDuties).produceBlock(ONE); }
public void onBlockProductionDue(final UInt64 slot) { execute(duties -> duties.produceBlock(slot)); }
DutyQueue { public void onBlockProductionDue(final UInt64 slot) { execute(duties -> duties.produceBlock(slot)); } }
DutyQueue { public void onBlockProductionDue(final UInt64 slot) { execute(duties -> duties.produceBlock(slot)); } DutyQueue(final SafeFuture<ScheduledDuties> futureDuties); }
DutyQueue { public void onBlockProductionDue(final UInt64 slot) { execute(duties -> duties.produceBlock(slot)); } DutyQueue(final SafeFuture<ScheduledDuties> futureDuties); void onBlockProductionDue(final UInt64 slot); void onAttestationCreationDue(final UInt64 slot); void onAttestationAggregationDue(final UInt64 slot); int countDuties(); synchronized void cancel(); }
DutyQueue { public void onBlockProductionDue(final UInt64 slot) { execute(duties -> duties.produceBlock(slot)); } DutyQueue(final SafeFuture<ScheduledDuties> futureDuties); void onBlockProductionDue(final UInt64 slot); void onAttestationCreationDue(final UInt64 slot); void onAttestationAggregationDue(final UInt64 slot); int countDuties(); synchronized void cancel();  }