@ 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 ) ; }
Watches specified IDs in a collection .