68                                 cf.whenCompleteAsync((r, e) -> {

    68                                 cf.whenCompleteAsync((r, e) -> {

    69                                     p.second.accept(consumer);

    69                                     p.second.accept(consumer);

    70                                     repeat(taskCompleter);

    70                                     repeat(taskCompleter);

    71                                 });

    71                                 });

    72                             }

    72                             }

    73                         }

    75                         }

    74                     }

    76                     }

    75 

    77 

    76                     private void repeat(DeferredCompleter taskCompleter) {

    78                     private void repeat(DeferredCompleter taskCompleter) {

    77                         taskCompleter.complete();

    79                         taskCompleter.complete();