             try await nio.initialDiscovery.get()
         }
         
+        init(nio: MongoCluster) {
+            self.nio = nio
+        }
+        
         public subscript(db: String) -> MongoDatabase.Async {
             MongoDatabase.Async(nio: nio[db])
         }

        public func upsertEncoded<Query: MongoKittenQuery, E: Encodable>(_ model: E, where query: Query) async throws -> UpdateReply {
            try await nio.upsertEncoded(model, where: query).get()
        }
    }
}


    public struct Async {
        public let nio: MongoCollection
        
        init(nio: MongoCollection) {
            self.nio = nio
        }
        
        public var name: String { nio.name }
        public var isInTransaction: Bool { nio.isInTransaction }
        
