code: @Override
    @SuppressWarnings("unchecked")
    public Stream<CompactChangeEvent<DocumentT>> watchCompact(final BsonValue... ids)
        throws InterruptedException, IOException {
      return operations.watch(
          new HashSet<>(Arrays.asList(ids)),
          true,
          documentClass
      ).execute(service);
    }
docs: Watches specified IDs in a collection. Requests a stream where the full document of update
  events, and several other unnecessary fields are omitted from the change event objects
  returned by the server. This can save on network usage when watching large documents
  
  @param ids the ids to watch.
  @return the stream of change events.