emulation of scala's async macro

TClient.java

private static void testRun(RLTable<TCRecord> table, TCMutator mutator, ClientActor client) {
    async(
        () -> mutator.$init(table),
        () -> {
            client.$run(table);
            return mutator.$run(table, 1000, null);
        },
        () -> table.$sync(),
        () -> client.$unsubscribe(table),
        () -> client.$checkCorrectness(table)
   ).then( (res, err) -> {
      if (err == null) {
          System.out.println("NEXT RUN");
          table.$sync();
          testRun(table, mutator, client);
      } else {
          System.out.println(err);
          System.exit(1);
      }
   });
}

// Same code with pure future chaining
private static void testRun(RLTable<TCRecord> table, TCMutator mutator, ClientActor client) {
    mutator.$init(table).then(() -> {
        client.$run(table);
        mutator.$run(table, 1000, null).then( () ->
            table.$sync().then( () ->
                client.$unsubscribe(table).then( () ->
                    client.$checkCorrectness(table).then((res, err) -> {
                        if (err == null) {
                            System.out.println("NEXT RUN");
                            table.$sync();
                            testRun(table, mutator, client);
                        } else {
                            System.out.println(err);
                            System.exit(1);
                        }
                    })
                )
            )
        );
    });
}