diff --git a/Sources/MongoKitten/CollectionHelpers/Collection+FindAndModify.swift b/Sources/MongoKitten/CollectionHelpers/Collection+FindAndModify.swift index 7915dc93..7db1ea5c 100644 --- a/Sources/MongoKitten/CollectionHelpers/Collection+FindAndModify.swift +++ b/Sources/MongoKitten/CollectionHelpers/Collection+FindAndModify.swift @@ -133,7 +133,7 @@ public final class FindAndModifyBuilder { sessionId: self.collection.sessionId ?? connection.implicitSessionId) } - .decode(FindAndModifyReply.self) + .decodeReply(FindAndModifyReply.self) ._mongoHop(to: self.collection.hoppedEventLoop) } diff --git a/Sources/MongoKitten/CollectionHelpers/Collection+Indexes.swift b/Sources/MongoKitten/CollectionHelpers/Collection+Indexes.swift index e5519613..debfc4d7 100644 --- a/Sources/MongoKitten/CollectionHelpers/Collection+Indexes.swift +++ b/Sources/MongoKitten/CollectionHelpers/Collection+Indexes.swift @@ -40,7 +40,7 @@ extension MongoCollection { request, namespace: namespace, sessionId: nil - ).decode(MongoCursorResponse.self).map { response in + ).decodeReply(MongoCursorResponse.self).map { response in return MongoCursor( reply: response.cursor, in: namespace,