@Override
  public WriteResult insertAll(Iterable<? extends T> docs) {
    return Publishers.blockingGet(writable.insertAll(docs));
  }
Blocking write operations on the repository
criteria/common/src/org/immutables/criteria/repository/sync/SyncWritable.java