SendChannel.sendBlocking extension method

Author: fvasco

core/kotlinx-coroutines-core/src/main/kotlin/kotlinx/coroutines/experimental/channels/Channels.kt

@@ -16,6 +16,8 @@
 
 package kotlinx.coroutines.experimental.channels
 
+import kotlinx.coroutines.experimental.runBlocking
+
 internal const val DEFAULT_CLOSE_MESSAGE = "Channel was closed"
 
 /**
@@ -47,3 +49,20 @@ public inline suspend fun <E> BroadcastChannel<E>.consumeEach(action: (E) -> Uni
 @Deprecated("binary compatibility with old code", level = DeprecationLevel.HIDDEN)
 public suspend fun <E> BroadcastChannel<E>.consumeEach(action: suspend (E) -> Unit) =
     consumeEach { action(it) }
+
+/**
+ * Adds [element] into to this channel, **blocking** the caller while this channel [Channel.isFull],
+ * or throws exception if the channel [Channel.isClosedForSend] (see [Channel.close] for details).
+ *
+ * This is a way to call [Channel.send] method inside a blocking code using [runBlocking],
+ * so this function should not be used from coroutine.
+ */
+public fun <E> SendChannel<E>.sendBlocking(element: E) {
+    // fast path
+    if (offer(element))
+        return
+    // slow path
+    runBlocking {
+        send(element)
+    }
+}