code: @Override
    @SuppressWarnings("unchecked")
    public Stream<ChangeEvent<DocumentT>> watch(final BsonValue... ids)
        throws InterruptedException, IOException {
      return operations.watch(
          new HashSet<>(Arrays.asList(ids)),
          false,
          documentClass
      ).execute(service);
    }
docs: Watches specified IDs in a collection.
  @param ids the ids to watch.
  @return the stream of change events.