As the second part of implementing change streams, we need to define a Watch struct that implements Operation. This operation should wrap the Aggregate operation, calling Aggregate::build and Aggregate::handle_response in its own respective build and handle_response methods.
Additionally, the watch methods on Client, Database, and Collection should be updated to create and execute a Watch operation.
- is duplicated by
-
RUST-971 Allow custom type to be used with aggregation
- Closed