@Override
  public CompletionStage<WriteResult> insertAll(Iterable<? extends T> docs) {
    return Publishers.toFuture(reactive.insertAll(docs));
  }
Writable which uses {@link CompletionStage} as return type
criteria/common/src/org/immutables/criteria/repository/async/AsyncWritable.java