class RetryingDutyLoader implements DutyLoader {

  @Override
  public SafeFuture<ScheduledDuties> loadDutiesForEpoch(final UInt64 epoch) {
    final SafeFuture<ScheduledDuties> duties = new SafeFuture<>();
    requestDuties(epoch, duties).propagateTo(duties);
    return duties;
  }

  public  RetryingDutyLoader(final AsyncRunner asyncRunner, final DutyLoader delegate);

}