Make examples runnable

* Also drop args from fun main

Author: AlexanderPrendota

core/kotlinx-coroutines-core/test/guide/example-basic-01.kt

@@ -7,7 +7,7 @@ package kotlinx.coroutines.guide.basic01
 
 import kotlinx.coroutines.*
 
-fun main(args: Array<String>) {
+fun main() {
     GlobalScope.launch { // launch new coroutine in background and continue
         delay(1000L) // non-blocking delay for 1 second (default time unit is ms)
         println("World!") // print after delay

core/kotlinx-coroutines-core/test/guide/example-basic-02.kt

@@ -7,7 +7,7 @@ package kotlinx.coroutines.guide.basic02
 
 import kotlinx.coroutines.*
 
-fun main(args: Array<String>) { 
+fun main() { 
     GlobalScope.launch { // launch new coroutine in background and continue
         delay(1000L)
         println("World!")

core/kotlinx-coroutines-core/test/guide/example-basic-02b.kt

@@ -7,7 +7,7 @@ package kotlinx.coroutines.guide.basic02b
 
 import kotlinx.coroutines.*
 
-fun main(args: Array<String>) = runBlocking<Unit> { // start main coroutine
+fun main() = runBlocking<Unit> { // start main coroutine
     GlobalScope.launch { // launch new coroutine in background and continue
         delay(1000L)
         println("World!")

core/kotlinx-coroutines-core/test/guide/example-basic-03.kt

@@ -7,11 +7,13 @@ package kotlinx.coroutines.guide.basic03
 
 import kotlinx.coroutines.*
 
-fun main(args: Array<String>) = runBlocking {
+fun main() = runBlocking {
+//sampleStart
     val job = GlobalScope.launch { // launch new coroutine and keep a reference to its Job
         delay(1000L)
         println("World!")
     }
     println("Hello,")
     job.join() // wait until child coroutine completes
+//sampleEnd    
 }

core/kotlinx-coroutines-core/test/guide/example-basic-03s.kt

@@ -7,7 +7,7 @@ package kotlinx.coroutines.guide.basic03s
 
 import kotlinx.coroutines.*
 
-fun main(args: Array<String>) = runBlocking { // this: CoroutineScope
+fun main() = runBlocking { // this: CoroutineScope
     launch { // launch new coroutine in the scope of runBlocking
         delay(1000L)
         println("World!")

core/kotlinx-coroutines-core/test/guide/example-basic-04.kt

@@ -7,7 +7,7 @@ package kotlinx.coroutines.guide.basic04
 
 import kotlinx.coroutines.*
 
-fun main(args: Array<String>) = runBlocking { // this: CoroutineScope
+fun main() = runBlocking { // this: CoroutineScope
     launch { 
         delay(200L)
         println("Task from runBlocking")

core/kotlinx-coroutines-core/test/guide/example-basic-05.kt

@@ -7,7 +7,7 @@ package kotlinx.coroutines.guide.basic05
 
 import kotlinx.coroutines.*
 
-fun main(args: Array<String>) = runBlocking {
+fun main() = runBlocking {
     launch { doWorld() }
     println("Hello,")
 }

core/kotlinx-coroutines-core/test/guide/example-basic-06.kt

@@ -7,7 +7,7 @@ package kotlinx.coroutines.guide.basic06
 
 import kotlinx.coroutines.*
 
-fun main(args: Array<String>) = runBlocking {
+fun main() = runBlocking {
     repeat(100_000) { // launch a lot of coroutines
         launch {
             delay(1000L)

core/kotlinx-coroutines-core/test/guide/example-basic-07.kt

@@ -7,12 +7,14 @@ package kotlinx.coroutines.guide.basic07
 
 import kotlinx.coroutines.*
 
-fun main(args: Array<String>) = runBlocking {
+fun main() = runBlocking {
+//sampleStart
     GlobalScope.launch {
         repeat(1000) { i ->
             println("I'm sleeping $i ...")
             delay(500L)
         }
     }
     delay(1300L) // just quit after delay
+//sampleEnd    
 }

core/kotlinx-coroutines-core/test/guide/example-cancel-01.kt

@@ -7,7 +7,8 @@ package kotlinx.coroutines.guide.cancel01
 
 import kotlinx.coroutines.*
 
-fun main(args: Array<String>) = runBlocking {
+fun main() = runBlocking {
+//sampleStart
     val job = launch {
         repeat(1000) { i ->
             println("I'm sleeping $i ...")
@@ -19,4 +20,5 @@ fun main(args: Array<String>) = runBlocking {
     job.cancel() // cancels the job
     job.join() // waits for job's completion 
     println("main: Now I can quit.")
+//sampleEnd    
 }

core/kotlinx-coroutines-core/test/guide/example-cancel-02.kt

@@ -7,7 +7,8 @@ package kotlinx.coroutines.guide.cancel02
 
 import kotlinx.coroutines.*
 
-fun main(args: Array<String>) = runBlocking {
+fun main() = runBlocking {
+//sampleStart
     val startTime = timeSource.currentTimeMillis()
     val job = launch(Dispatchers.Default) {
         var nextPrintTime = startTime
@@ -24,4 +25,5 @@ fun main(args: Array<String>) = runBlocking {
     println("main: I'm tired of waiting!")
     job.cancelAndJoin() // cancels the job and waits for its completion
     println("main: Now I can quit.")
+//sampleEnd    
 }

core/kotlinx-coroutines-core/test/guide/example-cancel-03.kt

@@ -7,7 +7,8 @@ package kotlinx.coroutines.guide.cancel03
 
 import kotlinx.coroutines.*
 
-fun main(args: Array<String>) = runBlocking {
+fun main() = runBlocking {
+//sampleStart
     val startTime = timeSource.currentTimeMillis()
     val job = launch(Dispatchers.Default) {
         var nextPrintTime = startTime
@@ -24,4 +25,5 @@ fun main(args: Array<String>) = runBlocking {
     println("main: I'm tired of waiting!")
     job.cancelAndJoin() // cancels the job and waits for its completion
     println("main: Now I can quit.")
+//sampleEnd    
 }

core/kotlinx-coroutines-core/test/guide/example-cancel-04.kt

@@ -7,7 +7,8 @@ package kotlinx.coroutines.guide.cancel04
 
 import kotlinx.coroutines.*
 
-fun main(args: Array<String>) = runBlocking {
+fun main() = runBlocking {
+//sampleStart
     val job = launch {
         try {
             repeat(1000) { i ->
@@ -22,4 +23,5 @@ fun main(args: Array<String>) = runBlocking {
     println("main: I'm tired of waiting!")
     job.cancelAndJoin() // cancels the job and waits for its completion
     println("main: Now I can quit.")
+//sampleEnd    
 }

core/kotlinx-coroutines-core/test/guide/example-cancel-05.kt

@@ -7,7 +7,8 @@ package kotlinx.coroutines.guide.cancel05
 
 import kotlinx.coroutines.*
 
-fun main(args: Array<String>) = runBlocking {
+fun main() = runBlocking {
+//sampleStart
     val job = launch {
         try {
             repeat(1000) { i ->
@@ -26,4 +27,5 @@ fun main(args: Array<String>) = runBlocking {
     println("main: I'm tired of waiting!")
     job.cancelAndJoin() // cancels the job and waits for its completion
     println("main: Now I can quit.")
+//sampleEnd    
 }

core/kotlinx-coroutines-core/test/guide/example-cancel-06.kt

@@ -7,11 +7,13 @@ package kotlinx.coroutines.guide.cancel06
 
 import kotlinx.coroutines.*
 
-fun main(args: Array<String>) = runBlocking {
+fun main() = runBlocking {
+//sampleStart
     withTimeout(1300L) {
         repeat(1000) { i ->
             println("I'm sleeping $i ...")
             delay(500L)
         }
     }
+//sampleEnd
 }

core/kotlinx-coroutines-core/test/guide/example-cancel-07.kt

@@ -7,7 +7,8 @@ package kotlinx.coroutines.guide.cancel07
 
 import kotlinx.coroutines.*
 
-fun main(args: Array<String>) = runBlocking {
+fun main() = runBlocking {
+//sampleStart
     val result = withTimeoutOrNull(1300L) {
         repeat(1000) { i ->
             println("I'm sleeping $i ...")
@@ -16,4 +17,5 @@ fun main(args: Array<String>) = runBlocking {
         "Done" // will get cancelled before it produces this result
     }
     println("Result is $result")
+//sampleEnd
 }

core/kotlinx-coroutines-core/test/guide/example-channel-01.kt

@@ -8,7 +8,8 @@ package kotlinx.coroutines.guide.channel01
 import kotlinx.coroutines.*
 import kotlinx.coroutines.channels.*
 
-fun main(args: Array<String>) = runBlocking {
+fun main() = runBlocking {
+//sampleStart
     val channel = Channel<Int>()
     launch {
         // this might be heavy CPU-consuming computation or async logic, we'll just send five squares
@@ -17,4 +18,5 @@ fun main(args: Array<String>) = runBlocking {
     // here we print five received integers:
     repeat(5) { println(channel.receive()) }
     println("Done!")
+//sampleEnd
 }

core/kotlinx-coroutines-core/test/guide/example-channel-02.kt

@@ -8,7 +8,8 @@ package kotlinx.coroutines.guide.channel02
 import kotlinx.coroutines.*
 import kotlinx.coroutines.channels.*
 
-fun main(args: Array<String>) = runBlocking {
+fun main() = runBlocking {
+//sampleStart
     val channel = Channel<Int>()
     launch {
         for (x in 1..5) channel.send(x * x)
@@ -17,4 +18,5 @@ fun main(args: Array<String>) = runBlocking {
     // here we print received values using `for` loop (until the channel is closed)
     for (y in channel) println(y)
     println("Done!")
+//sampleEnd
 }

core/kotlinx-coroutines-core/test/guide/example-channel-03.kt

@@ -12,8 +12,10 @@ fun CoroutineScope.produceSquares(): ReceiveChannel<Int> = produce {
     for (x in 1..5) send(x * x)
 }
 
-fun main(args: Array<String>) = runBlocking {
+fun main() = runBlocking {
+//sampleStart
     val squares = produceSquares()
     squares.consumeEach { println(it) }
     println("Done!")
+//sampleEnd
 }

core/kotlinx-coroutines-core/test/guide/example-channel-04.kt

@@ -8,19 +8,24 @@ package kotlinx.coroutines.guide.channel04
 import kotlinx.coroutines.*
 import kotlinx.coroutines.channels.*
 
+fun main() = runBlocking {
+//sampleStart
+    val numbers = produceNumbers() // produces integers from 1 and on
+    val squares = square(numbers) // squares integers
+    for (i in 1..5) println(squares.receive()) // print first five
+    println("Done!") // we are done
+    coroutineContext.cancelChildren() // cancel children coroutines
+//sampleEnd
+}
+
+fun CoroutineScope.produceSquares(): ReceiveChannel<Int> = produce {
+    for (x in 1..5) send(x * x)
+}
+
 fun CoroutineScope.produceNumbers() = produce<Int> {
     var x = 1
     while (true) send(x++) // infinite stream of integers starting from 1
 }
-
 fun CoroutineScope.square(numbers: ReceiveChannel<Int>): ReceiveChannel<Int> = produce {
     for (x in numbers) send(x * x)
 }
-
-fun main(args: Array<String>) = runBlocking {
-    val numbers = produceNumbers() // produces integers from 1 and on
-    val squares = square(numbers) // squares integers
-    for (i in 1..5) println(squares.receive()) // print first five
-    println("Done!") // we are done
-    coroutineContext.cancelChildren() // cancel children coroutines
-}

core/kotlinx-coroutines-core/test/guide/example-channel-05.kt

@@ -7,23 +7,24 @@ package kotlinx.coroutines.guide.channel05
 
 import kotlinx.coroutines.*
 import kotlinx.coroutines.channels.*
-import kotlin.coroutines.*
 
-fun CoroutineScope.numbersFrom(start: Int) = produce<Int> {
-    var x = start
-    while (true) send(x++) // infinite stream of integers from start
-}
-
-fun CoroutineScope.filter(numbers: ReceiveChannel<Int>, prime: Int) = produce<Int> {
-    for (x in numbers) if (x % prime != 0) send(x)
-}
-
-fun main(args: Array<String>) = runBlocking {
+fun main() = runBlocking {
+//sampleStart
     var cur = numbersFrom(2)
     for (i in 1..10) {
         val prime = cur.receive()
         println(prime)
         cur = filter(cur, prime)
     }
     coroutineContext.cancelChildren() // cancel all children to let main finish
+//sampleEnd    
+}
+
+fun CoroutineScope.numbersFrom(start: Int) = produce<Int> {
+    var x = start
+    while (true) send(x++) // infinite stream of integers from start
+}
+
+fun CoroutineScope.filter(numbers: ReceiveChannel<Int>, prime: Int) = produce<Int> {
+    for (x in numbers) if (x % prime != 0) send(x)
 }

core/kotlinx-coroutines-core/test/guide/example-channel-06.kt

@@ -8,6 +8,15 @@ package kotlinx.coroutines.guide.channel06
 import kotlinx.coroutines.*
 import kotlinx.coroutines.channels.*
 
+fun main() = runBlocking<Unit> {
+//sampleStart
+    val producer = produceNumbers()
+    repeat(5) { launchProcessor(it, producer) }
+    delay(950)
+    producer.cancel() // cancel producer coroutine and thus kill them all
+//sampleEnd
+}
+
 fun CoroutineScope.produceNumbers() = produce<Int> {
     var x = 1 // start from 1
     while (true) {
@@ -21,10 +30,3 @@ fun CoroutineScope.launchProcessor(id: Int, channel: ReceiveChannel<Int>) = laun
         println("Processor #$id received $msg")
     }    
 }
-
-fun main(args: Array<String>) = runBlocking<Unit> {
-    val producer = produceNumbers()
-    repeat(5) { launchProcessor(it, producer) }
-    delay(950)
-    producer.cancel() // cancel producer coroutine and thus kill them all
-}

core/kotlinx-coroutines-core/test/guide/example-channel-07.kt

@@ -7,21 +7,22 @@ package kotlinx.coroutines.guide.channel07
 
 import kotlinx.coroutines.*
 import kotlinx.coroutines.channels.*
-import kotlin.coroutines.*
 
-suspend fun sendString(channel: SendChannel<String>, s: String, time: Long) {
-    while (true) {
-        delay(time)
-        channel.send(s)
-    }
-}
-
-fun main(args: Array<String>) = runBlocking {
+fun main() = runBlocking {
+//sampleStart
     val channel = Channel<String>()
     launch { sendString(channel, "foo", 200L) }
     launch { sendString(channel, "BAR!", 500L) }
     repeat(6) { // receive first six
         println(channel.receive())
     }
     coroutineContext.cancelChildren() // cancel all children to let main finish
+//sampleEnd
+}
+
+suspend fun sendString(channel: SendChannel<String>, s: String, time: Long) {
+    while (true) {
+        delay(time)
+        channel.send(s)
+    }
 }

core/kotlinx-coroutines-core/test/guide/example-channel-08.kt

@@ -7,9 +7,9 @@ package kotlinx.coroutines.guide.channel08
 
 import kotlinx.coroutines.*
 import kotlinx.coroutines.channels.*
-import kotlin.coroutines.*
 
-fun main(args: Array<String>) = runBlocking<Unit> {
+fun main() = runBlocking<Unit> {
+//sampleStart
     val channel = Channel<Int>(4) // create buffered channel
     val sender = launch { // launch sender coroutine
         repeat(10) {
@@ -20,4 +20,5 @@ fun main(args: Array<String>) = runBlocking<Unit> {
     // don't receive anything... just wait....
     delay(1000)
     sender.cancel() // cancel sender coroutine
+//sampleEnd    
 }