synchs up contents

Author: pmhsfelix

build.gradle

@@ -56,6 +56,9 @@ dependencies {
     }
     testCompile group: 'junit', name: 'junit', version: '4.12'
     compile group: 'org.slf4j', name: 'slf4j-simple', version: '1.7.25'
+
+    compile group: 'io.reactivex', name: 'rxjava', version: '1.3.8'
+
 }
 
 compileKotlin {

src/main/kotlin/org/pedrofelix/kotlin/examples/buildstuff18.kt

@@ -20,7 +20,7 @@ fun blockingOperation(input: Int): Int {
 }
 
 private val executor = Executors.newScheduledThreadPool(5)
-fun asyncOperationWithCallback(input: Int, callback: (Int) -> Unit): Unit {
+qfun asyncOperationWithCallback(input: Int, callback: (Int) -> Unit): Unit {
     executor.schedule({ callback(input + 42) }, 1000, TimeUnit.MILLISECONDS)
 }
 

src/main/kotlin/org/pedrofelix/kotlin/examples/spring-examples.kt

@@ -10,6 +10,7 @@ import org.springframework.web.bind.annotation.RestController
 import org.springframework.web.context.request.async.AsyncRequestTimeoutException
 import org.springframework.web.context.request.async.DeferredResult
 import java.util.concurrent.Executors
+import kotlin.coroutines.ContinuationInterceptor
 import kotlin.coroutines.CoroutineContext
 import kotlin.coroutines.EmptyCoroutineContext
 
@@ -96,6 +97,7 @@ class TheController {
     @GetMapping("/example-with-dispatcher")
     fun getExampleWithDispatcher() = asyncHandler {
         withContext(exampleDispatcher) {
+            log.info("using interceptor {}", coroutineContext[ContinuationInterceptor])
             example7(1)
         }
     }

src/test/kotlin/org/pedrofelix/kotlin/examples/RandomTests.kt

@@ -0,0 +1,28 @@
+package org.pedrofelix.kotlin.examples
+
+import kotlinx.coroutines.*
+import org.junit.Test
+import org.pedrofelix.experiments.ScopeExamples
+import org.slf4j.LoggerFactory
+import kotlin.coroutines.ContinuationInterceptor
+import kotlin.coroutines.coroutineContext
+
+private val log = LoggerFactory.getLogger(RandomTests::class.java)
+
+class RandomTests {
+
+    private suspend fun doSomethingWith(i: Int) {
+        log.info("ctx {}", coroutineContext)
+    }
+
+    @Test
+    fun first() {
+        val items = listOf(1,2,3,4)
+        runBlocking {
+            withContext(Dispatchers.IO) {
+                log.info("ctx {}", coroutineContext)
+                items.forEach { launch { doSomethingWith(it) } }
+            }
+        }
+    }
+}

src/test/kotlin/org/pedrofelix/kotlin/examples/RxExampleTests.kt

@@ -0,0 +1,23 @@
+package org.pedrofelix.kotlin.examples
+
+import kotlinx.coroutines.GlobalScope
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.launch
+import org.junit.Test
+import rx.Single
+
+class RxExampleTests {
+
+    @Test
+    fun test() {
+
+        val s = Single.create<String> { obs ->
+            val job = GlobalScope.launch {
+                delay(1000)
+                obs.onSuccess("done")
+            }
+            // ...
+            job.cancel()
+        }
+    }
+}