coroutines fixes

commons-core/src/main/kotlin/ru/sokomishalov/commons/core/collections/CoroutineIterableExtensions.kt

@@ -49,7 +49,7 @@ suspend inline fun <T, R> Iterable<T>.aMap(
 suspend inline fun <T, R> Iterable<T>.aFlatMap(
         scope: CoroutineScope? = null,
         context: CoroutineContext = scope?.coroutineContext ?: EmptyCoroutineContext,
-        crossinline transform: suspend CoroutineScope.(T) -> Iterable<R>
+        noinline transform: suspend CoroutineScope.(T) -> Iterable<R>
 ): List<R> = withContext(context) {
     val destination = mutableListOf<R>()
     map { async { destination.addAll(transform(it)) } }.awaitAll()
@@ -59,7 +59,7 @@ suspend inline fun <T, R> Iterable<T>.aFlatMap(
 suspend inline fun <T> Iterable<T>.aFilter(
         scope: CoroutineScope? = null,
         context: CoroutineContext = scope?.coroutineContext ?: EmptyCoroutineContext,
-        crossinline predicate: suspend CoroutineScope.(T) -> Boolean
+        noinline predicate: suspend CoroutineScope.(T) -> Boolean
 ): List<T> = withContext(context) {
     val destination = mutableListOf<T>()
     map { async { if (predicate(it)) destination.add(it) } }.awaitAll()

commons-core/src/main/kotlin/ru/sokomishalov/commons/core/collections/CoroutineMapExtensions.kt

@@ -17,7 +17,23 @@
 
 package ru.sokomishalov.commons.core.collections
 
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.async
+import kotlinx.coroutines.awaitAll
+import kotlinx.coroutines.withContext
+import ru.sokomishalov.commons.core.common.unit
+import kotlin.coroutines.CoroutineContext
+import kotlin.coroutines.EmptyCoroutineContext
+
 
 /**
  * @author sokomishalov
  */
+
+suspend inline fun <K, V> Map<out K, V>.aForEach(
+        scope: CoroutineScope? = null,
+        context: CoroutineContext = scope?.coroutineContext ?: EmptyCoroutineContext,
+        noinline block: suspend CoroutineScope.(Map.Entry<K, V>) -> Unit
+): Unit = withContext(context) {
+    map { async { block(it) } }.awaitAll().unit()
+}

commons-core/src/main/kotlin/ru/sokomishalov/commons/core/collections/IterableExtensions.kt

@@ -22,7 +22,5 @@ package ru.sokomishalov.commons.core.collections
  */
 
 inline fun <reified K, V> Iterable<Map<K, V>>.toMap(): Map<K, V> {
-    return fold(mutableMapOf(), { acc, map ->
-        acc.putAll(map).let { acc }
-    })
+    return fold(mutableMapOf(), { acc, map -> acc.putAll(map).let { acc } })
 }