The original intention of this test was to verify resumability in the event of a dropped connection; however, since socketTimeoutMS and maxAwaitTimeMS are fixed values, we cannot test a dropped connection followed by a successful resume. Instead, we will test that the driver attempts to resume once and only once before we expect a socket timeout after the second attempt.

Note: ChangeStream::rewind() does not currently resume (see: PHPLIB-322)

Change streams require a replica set.

Refactoring the change stream tests to execute Watch directly highlighted a bug where no read preference was available during the resume process. This ensures that a read preference is always set, and also specifies a "fullDocument" default (consistent with other drivers).

For consistency with other operation functional tests, this now constructs and executes operation classes directly.

The batchSize option for change streams is not identical to the aggregate option, so they should not share the same text. That said, the batchSize option likely has no effect on the resulting change stream (see: PHPLIB-321).

This makes the constructor consistent with other classes (e.g. Client, GridFS\Bucket) and also ensures that we don't have required parameters trailing optional arguments (i.e. options array).

This makes the operation consistent with the Collection method name and avoids the naming conflict with the ChangeStream iterator class.

PHPLIB-292: Apply type map to offsetGet and throw exceptions for mutate methods in TypeMapArrayIterator

The Operation classes were previously relying on MongoDB\Tests\Collection\FunctionalTestCase, so they required additional changes to initialize a Collection instance for asserting outcome of write operations.

This inserts an additional document so that we can assert that the first rewind and next calls do not block, while the last next does issue a getMore and block.