salamanders

@ExperimentalCoroutinesApi
fun CollectionReference.toFlow(): Flow<DocumentChange> = callbackFlow {
    val snapshotListener = this@toFlow.addSnapshotListener { snapshots, e ->
        if (e != null) {
            logger.error { "${this@toFlow.path} listen:error:$e" }
            cancel(CancellationException("Collection Listener Error in ${this@toFlow.path}", e))
            return@addSnapshotListener
        }
        for (dc in snapshots!!.documentChanges) {

elizarov

import kotlin.coroutines.*
import kotlin.coroutines.intrinsics.*

/**
 * Implementation for Delimited Continuations `shift`/`reset` primitives via Kotlin Coroutines.
 * See [https://en.wikipedia.org/wiki/Delimited_continuation].
 *
 * The following LISP code:
 *
 * ```

AndrewReitz

pluginManagement {
    repositories {
        gradlePluginPortal()
        google()
        jcenter()
        maven { url = uri("https://maven.fabric.io/public") }
    }

    resolutionStrategy {
        eachPlugin {