Introduce suspending consumeEachRemaining (#22)

Author: Sergey Mashkov

binary-compatibility-validator/reference-public-api/kotlinx-coroutines-io-jvm.txt

@@ -262,6 +262,7 @@ public abstract interface class kotlinx/coroutines/io/LookAheadSession {
 
 public final class kotlinx/coroutines/io/LookAheadSessionKt {
 	public static final fun consumeEachRemaining (Lkotlinx/coroutines/io/LookAheadSession;Lkotlin/jvm/functions/Function1;)V
+	public static final fun consumeEachRemaining (Lkotlinx/coroutines/io/LookAheadSuspendSession;Lkotlin/jvm/functions/Function2;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
 }
 
 public abstract interface class kotlinx/coroutines/io/LookAheadSuspendSession : kotlinx/coroutines/io/LookAheadSession {

kotlinx-coroutines-io/kotlinx-coroutines-io-jvm/src/main/kotlin/kotlinx/coroutines/experimental/io/LookAheadSession.kt

@@ -45,3 +45,21 @@ inline fun LookAheadSession.consumeEachRemaining(visitor: (ByteBuffer) -> Boolea
     } while (true)
 }
 
+@Suppress("REDUNDANT_INLINE_SUSPEND_FUNCTION_TYPE")
+@ExperimentalIoApi
+suspend inline fun LookAheadSuspendSession.consumeEachRemaining(visitor: suspend (ByteBuffer) -> Boolean) {
+    do {
+        val buffer = request(0, 1)
+        if (buffer == null) {
+            if (!awaitAtLeast(1)) break
+            continue
+        }
+
+        val s = buffer.remaining()
+        val rc = visitor(buffer)
+        consumed(s)
+
+        if (!rc) break
+    } while (true)
+}
+