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<Document : Any>(
 	override val type: KType
 		get() = upstream.type
 
-	override fun filter(filter: FilterQuery<Document>.() -> Unit): MongoCollection<Document> =
+	override fun filter(filter: FilterQuery<Document>.() -> Unit): CoroutineMongoCollection<Document> =
 		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<Document : Any> : MongoCollection<Document> {
 	): UpsertResult
 
 	override fun aggregate(): CoroutineMongoAggregationPipeline<Document>
+
+	override fun filter(filter: FilterQuery<Document>.() -> Unit): CoroutineMongoCollection<Document>
 }