     }
     
     func testChangeStream() throws {
+        guard cluster.wireVersion?.supportsReplicaTransactions == true && cluster.isCluster else {
+            return
+        }
+        
         do {
             let collection = cluster[dbName]["test"]
             


let dbName = "test"

class CRUDTests : XCTestCase {
    let group = MultiThreadedEventLoopGroup(numberOfThreads: 1)
    
//    let settings = ConnectionSettings(

    }
    
    func testTransactions() throws {
        guard cluster.wireVersion?.supportsReplicaTransactions == true && cluster.isCluster else {
            return
        }

        let db = cluster[dbName]
        let users = db["users"]
        _ = try db["users"].insert(["username": "Creating collection user"]).wait()
