@Test public void onAttestationAggregationDue_shouldDeferUntilDutiesLoaded() { duties.onAttestationAggregationDue(ONE); verifyNoInteractions(scheduledDuties); scheduledDutiesFuture.complete(scheduledDuties); verify(scheduledDuties).performAggregation(ONE); }
public void onAttestationAggregationDue(final UInt64 slot) { execute(duties -> duties.performAggregation(slot)); }
DutyQueue { public void onAttestationAggregationDue(final UInt64 slot) { execute(duties -> duties.performAggregation(slot)); } }
DutyQueue { public void onAttestationAggregationDue(final UInt64 slot) { execute(duties -> duties.performAggregation(slot)); } DutyQueue(final SafeFuture<ScheduledDuties> futureDuties); }
DutyQueue { public void onAttestationAggregationDue(final UInt64 slot) { execute(duties -> duties.performAggregation(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 onAttestationAggregationDue(final UInt64 slot) { execute(duties -> duties.performAggregation(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();  }