Tetraquark

import ru.tetraquark.kotlin.playground.shared.eventbus.EventBus
import kotlin.native.concurrent.TransferMode
import kotlin.native.concurrent.Worker
import kotlin.native.concurrent.freeze

class RefHolder<T>(ref: T?) {
    var ref: T? = ref
        get() {
            val tmp = field
            ref = null

Tetraquark

import kotlinx.atomicfu.atomic
import kotlinx.atomicfu.getAndUpdate
import kotlin.reflect.KClass

typealias Observer = (Any) -> Unit

object EventBus {

    private val observers = atomic(mutableMapOf<KClass<out Any>, List<Observer>>())

Tetraquark

curl --location --request POST 'https://fcm.googleapis.com/fcm/send' \
--header 'Authorization: key=API_ACCESS_KEY' \
--header 'Content-Type: application/json' \
--data-raw '{
    "to": "CLIENT_PUSH_TOKEN",
    "notification": {
        "body": "Push text message",
        "title": "Push title"
    },
    "data": {

Tetraquark

{
    "to": "CLIENT_PUSH_TOKEN",
    "notification": {
        "body": "Push text message",
        "title": "Push title"
    },
    "data": {
        "some_important_id": "1234"
    }
}

Tetraquark

public suspend fun send(element: E)
public fun offer(element: E): Boolean

Tetraquark

public fun close(cause: Throwable? = null): Boolean

Tetraquark

for (item in channel) {
    // do something with item
}

Tetraquark

public suspend fun receive(): E
public fun poll(): E?

Tetraquark

public fun cancel(cause: CancellationException? = null)

Tetraquark

import kotlinx.coroutines.channels.produce

val receiveChannel = produce(context = Dispatchers.Default) {
    for (i in 0..10) {
        send(i)
    }
}