Enables coroutine support for MongoDB operations using the Reactive Streams Java Driver. Simplifies database interactions, allowing suspending calls and integration with Kotlin Flow for reactive data handling.
-blue.svg)
Kotlin coroutine support for MongoDB built on top of the official MongoDB Reactive Streams Java Driver.
build.gradle.kts:
dependencies {
implementation("io.fluidsonic.mongo:fluid-mongo:1.9.0")
}
import io.fluidsonic.mongo.MongoClients
import org.bson.Document
suspend fun main() {
val collection = MongoClients.create()
.getDatabase("test")
.getCollection("test")
collection.insertOne(mapOf("hello" to "world")) // suspending call
collection.insertOne(mapOf( to ))
collection.find().collect { document ->
println(document)
}
}
Output:
Document{{_id=5bb6b56f9cfa62686b5afc87, hello=world}}
Document{{_id=5bb6b56f9cfa62686b5afc88, it's=so easy!}}
Apache 2.0
Surfaced from shared tags and platforms — no rankings paid for.