docs: @SuppressWarnings("unchecked")
      <T> ICompletableFuture<Map<Integer, T>> invokeAsync() {
          assert !invoked : "already invoked";
          invoked = true;
          ensureNotCallingFromPartitionOperationThread();
          invokeOnAllPartitions();
          return future;
      }