From dd3b9f36740c943353082c33c95aa9f49b1ea582 Mon Sep 17 00:00:00 2001
From: InsanusMokrassar <ovsyannikov.alexey95@gmail.com>
Date: Sat, 26 Sep 2020 22:08:39 +0600
Subject: [PATCH] add coroutines utils

---
 .../dev/inmo/micro_utils/coroutines/Actor.kt  | 19 +++++++++++++++++
 .../micro_utils/coroutines/BroadcastFlow.kt   | 21 +++++++++++++++++++
 .../coroutines/DoOutsideOfCoroutine.kt        | 15 +++++++++++++
 3 files changed, 55 insertions(+)
 create mode 100644 coroutines/src/commonMain/kotlin/dev/inmo/micro_utils/coroutines/Actor.kt
 create mode 100644 coroutines/src/commonMain/kotlin/dev/inmo/micro_utils/coroutines/BroadcastFlow.kt
 create mode 100644 coroutines/src/commonMain/kotlin/dev/inmo/micro_utils/coroutines/DoOutsideOfCoroutine.kt

diff --git a/coroutines/src/commonMain/kotlin/dev/inmo/micro_utils/coroutines/Actor.kt b/coroutines/src/commonMain/kotlin/dev/inmo/micro_utils/coroutines/Actor.kt
new file mode 100644
index 00000000000..310d67c32f1
--- /dev/null
+++ b/coroutines/src/commonMain/kotlin/dev/inmo/micro_utils/coroutines/Actor.kt
@@ -0,0 +1,19 @@
+package dev.inmo.micro_utils.coroutines
+
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.channels.Channel
+import kotlinx.coroutines.launch
+
+fun <T> CoroutineScope.actor(
+    channelCapacity: Int = Channel.UNLIMITED,
+    block: suspend (T) -> Unit
+): Channel<T> {
+    val channel = Channel<T>(channelCapacity)
+    launch {
+        for (data in channel) {
+            block(data)
+        }
+    }
+    return channel
+}
+
diff --git a/coroutines/src/commonMain/kotlin/dev/inmo/micro_utils/coroutines/BroadcastFlow.kt b/coroutines/src/commonMain/kotlin/dev/inmo/micro_utils/coroutines/BroadcastFlow.kt
new file mode 100644
index 00000000000..d3ff5b0b277
--- /dev/null
+++ b/coroutines/src/commonMain/kotlin/dev/inmo/micro_utils/coroutines/BroadcastFlow.kt
@@ -0,0 +1,21 @@
+package dev.inmo.micro_utils.coroutines
+
+import kotlinx.coroutines.channels.*
+import kotlinx.coroutines.flow.*
+
+@Suppress("FunctionName")
+fun <T> BroadcastFlow(
+    internalChannelSize: Int = Channel.BUFFERED
+): BroadcastFlow<T> {
+    val channel = BroadcastChannel<T>(internalChannelSize)
+
+    return BroadcastFlow(
+        channel,
+        channel.asFlow()
+    )
+}
+
+class BroadcastFlow<T> internal constructor(
+    private val channel: BroadcastChannel<T>,
+    private val flow: Flow<T>
+): Flow<T> by flow, SendChannel<T> by channel
diff --git a/coroutines/src/commonMain/kotlin/dev/inmo/micro_utils/coroutines/DoOutsideOfCoroutine.kt b/coroutines/src/commonMain/kotlin/dev/inmo/micro_utils/coroutines/DoOutsideOfCoroutine.kt
new file mode 100644
index 00000000000..a4a7e2b912b
--- /dev/null
+++ b/coroutines/src/commonMain/kotlin/dev/inmo/micro_utils/coroutines/DoOutsideOfCoroutine.kt
@@ -0,0 +1,15 @@
+package dev.inmo.micro_utils.coroutines
+
+import kotlin.coroutines.*
+
+/**
+ * Call this method in case you need to do something in common thread (like reading of file in JVM)
+ */
+suspend fun <T> doOutsideOfCoroutine(block: () -> T): T = suspendCoroutine {
+    try {
+        it.resume(block())
+    } catch (e: Throwable) {
+        it.resumeWithException(e)
+    }
+}
+