fluidsonic

@file:OptIn(ExperimentalTime::class)

import kotlinx.coroutines.*
import kotlin.time.*


suspend fun main() {
    coroutineScope {
        println("Launching tasks…")

fluidsonic

// Dependencies:
// implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.3.9")
// implementation("org.jetbrains.kotlinx:atomicfu:0.14.4")

import kotlinx.atomicfu.*
import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*
import kotlinx.coroutines.selects.*
import java.io.*
import kotlin.coroutines.*

fluidsonic

fun <T> Flow<T>.shareIn(scope: CoroutineScope): Flow<T> {
    val upstream = this
    var broadcastChannel: BroadcastChannel<T>? = null
    val mutex = Mutex()
    var subscriberCount = 0

    return flow {
        val activeChannel = mutex.withLock {
            subscriberCount += 1
            broadcastChannel ?: upstream.broadcastIn(scope).also {

fluidsonic

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*


private val undefined = Any()

internal fun <T> Iterable<Flow<T>>.combineLatest(): Flow<List<T>> =
    combineLatest { it }

fluidsonic

import io.ktor.application.*
import io.ktor.client.*
import io.ktor.client.engine.cio.*
import io.ktor.client.request.*
import io.ktor.client.statement.*
import io.ktor.http.*
import io.ktor.response.*
import io.ktor.routing.*
import io.ktor.server.engine.*
import io.ktor.server.netty.*

fluidsonic

import io.ktor.application.*
import io.ktor.client.*
import io.ktor.client.engine.*
import io.ktor.client.engine.apache.*
import io.ktor.client.engine.cio.*
import io.ktor.client.engine.jetty.*
import io.ktor.client.engine.okhttp.*
import io.ktor.client.request.*
import io.ktor.client.statement.*
import io.ktor.http.*

fluidsonic

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*

/* Output:

cache collected:               initial
flow1 (collector 1) collected: initial
flow1 (collector 2) collected: initial
flow2 (collector 1) collected: initial

fluidsonic

/* Output

Collecting 2 elements…
upstream -> hot
emit: 0
resumed
collect: 0
Expensive work on 0 (isPaused = false)…
Expensive work on 0 (isPaused = false)…
Expensive work on 0 (isPaused = false)…

fluidsonic

@JsName("require")
external fun asset(path: String): String

// in a React builder
img(src = asset("image.png")) {}

fluidsonic

public external interface StringBuilder


public inline fun StringBuilder.append(value: Any) {
	append("$value")
}


public inline fun StringBuilder.append(string: String) {
	if (string != "")