Skip to content

Kotlin coroutine support for MongoDB built on top of the official Reactive Streams Java Driver

License

Notifications You must be signed in to change notification settings

fluidsonic/fluid-mongo

Repository files navigation

fluid-mongo

Maven Central Kotlin MongoDB #fluid-libraries Slack Channel

Kotlin coroutine support for MongoDB built on top of the official MongoDB Reactive Streams Java Driver.

Installation

build.gradle.kts:

dependencies {
    implementation("io.fluidsonic.mongo:fluid-mongo:1.7.0")
}

Example

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("it's" to "so easy!"))  // suspending call

    collection.find().collect { document ->  // Kotlin Flow
        println(document)
    }
}

Output:

Document{{_id=5bb6b56f9cfa62686b5afc87, hello=world}}
Document{{_id=5bb6b56f9cfa62686b5afc88, it's=so easy!}}

License

Apache 2.0


Awesome Kotlin

About

Kotlin coroutine support for MongoDB built on top of the official Reactive Streams Java Driver

Topics

Resources

License

Stars

Watchers

Forks

Packages

No packages published

Languages