PHPLIB-461: Fix ChangeStream tests on sharded clusters

Author: alcaeus

src/ChangeStream.php

@@ -44,6 +44,7 @@ class ChangeStream implements Iterator
         136, // CappedPositionLost
         237, // CursorKilled
         11601, // Interrupted
+        280, // ChangeStreamFatalError
     ];
 
     private $resumeCallable;
@@ -171,6 +172,11 @@ private function isResumableError(RuntimeException $exception)
             return false;
         }
 
+        /* The ServerException doesn't expose the NonResumableChangeStreamError
+         * label. Thus, the error code for the corresponding server exception
+         * has been marked as non-resumable. This can be reverted once PHPC-1419
+         * is fixed.
+         */
         if ($exception->hasErrorLabel('NonResumableChangeStreamError')) {
             return false;
         }

tests/DocumentationExamplesTest.php

@@ -928,6 +928,10 @@ public function testChangeStreamExample_1_4()
     {
         $this->skipIfChangeStreamIsNotSupported();
 
+        if ($this->isShardedCluster()) {
+            $this->markTestSkipped('Test does not apply on sharded clusters: need more than a single getMore call on the change stream.');
+        }
+
         $db = new Database($this->manager, $this->getDatabaseName());
         $db->dropCollection('inventory');
         $db->createCollection('inventory');

tests/FunctionalTestCase.php

@@ -320,9 +320,6 @@ protected function skipIfChangeStreamIsNotSupported()
                 if (!$this->isShardedClusterUsingReplicasets()) {
                     $this->markTestSkipped('$changeStream is only supported with replicasets');
                 }
-
-                // Temporarily skip tests because of an issue with change streams in the driver
-                $this->markTestSkipped('$changeStreams currently don\'t on replica sets');
                 break;
 
             case Server::TYPE_RS_PRIMARY: