From 751e6ad884c03b94678dd2126c0f6828798af9c8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Ivan=20=E2=80=9CCLOVIS=E2=80=9D=20Canet?= Date: Mon, 10 Aug 2026 23:22:29 +0200 Subject: [PATCH] feat(driver-coroutines): Missing specialization of filter() --- .../src/jvmMain/kotlin/CoroutineFilteredMongoCollectionImpl.kt | 3 +-- .../src/jvmMain/kotlin/CoroutineMongoCollection.kt | 2 ++ 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/driver-coroutines/src/jvmMain/kotlin/CoroutineFilteredMongoCollectionImpl.kt b/driver-coroutines/src/jvmMain/kotlin/CoroutineFilteredMongoCollectionImpl.kt index 93183cdf..9fa479f7 100644 --- a/driver-coroutines/src/jvmMain/kotlin/CoroutineFilteredMongoCollectionImpl.kt +++ b/driver-coroutines/src/jvmMain/kotlin/CoroutineFilteredMongoCollectionImpl.kt @@ -16,7 +16,6 @@ package opensavvy.ktmongo.coroutines -import opensavvy.ktmongo.api.MongoCollection import opensavvy.ktmongo.api.MongoIterable import opensavvy.ktmongo.api.operations.UpdateOperations import opensavvy.ktmongo.bson.official.BsonFactory @@ -52,7 +51,7 @@ private class CoroutineFilteredMongoCollectionImpl( override val type: KType get() = upstream.type - override fun filter(filter: FilterQuery.() -> Unit): MongoCollection = + override fun filter(filter: FilterQuery.() -> Unit): CoroutineMongoCollection = upstream.filter { globalFilter() filter() diff --git a/driver-coroutines/src/jvmMain/kotlin/CoroutineMongoCollection.kt b/driver-coroutines/src/jvmMain/kotlin/CoroutineMongoCollection.kt index 6e2e1f59..8057bd2c 100644 --- a/driver-coroutines/src/jvmMain/kotlin/CoroutineMongoCollection.kt +++ b/driver-coroutines/src/jvmMain/kotlin/CoroutineMongoCollection.kt @@ -93,4 +93,6 @@ interface CoroutineMongoCollection : MongoCollection { ): UpsertResult override fun aggregate(): CoroutineMongoAggregationPipeline + + override fun filter(filter: FilterQuery.() -> Unit): CoroutineMongoCollection } -- 2.51.2