Merge pull request #631

Author: jmikola

src/Operation/Watch.php

@@ -213,11 +213,6 @@ final public function commandSucceeded(CommandSucceededEvent $event)
      */
     public function execute(Server $server)
     {
-        $inTransaction = isset($this->options['session']) && $this->options['session']->isInTransaction();
-        if ($inTransaction && isset($this->options['readConcern'])) {
-            throw UnsupportedException::readConcernNotSupportedInTransaction();
-        }
-
         return new ChangeStream($this->executeAggregate($server), $this->resumeCallable);
     }
 

tests/Collection/CollectionFunctionalTest.php

@@ -551,6 +551,17 @@ function($collection, $session, $options = []) {
                     );
                 }, 'w'
             ],
+
+            /* Disabled, as it's illegal to use change streams in transactions
+            [
+                function($collection, $session, $options = []) {
+                    $collection->watch(
+                        [],
+                        ['session' => $session] + $options
+                    );
+                }, 'r'
+            ],
+            */
         ];
     }