Replace deprecated setCancellation with onDipose for Project Reactor

Liming.Shi · elizarov · commit d0597e7e0bf6 · 2017-08-03T11:07:26.000-07:00
reactor.core.Cancellation is removed from project reactor from 3.1.0.M1
diff --git a/reactive/kotlinx-coroutines-reactor/src/main/kotlin/kotlinx/coroutines/experimental/reactor/Mono.kt b/reactive/kotlinx-coroutines-reactor/src/main/kotlin/kotlinx/coroutines/experimental/reactor/Mono.kt
@@ -43,7 +43,7 @@ fun <T> mono(
     val newContext = newCoroutineContext(context)
     val coroutine = MonoCoroutine(newContext, sink)
     coroutine.initParentJob(context[Job])
-    sink.setCancellation(coroutine)
+    sink.onDispose(coroutine)
     block.startCoroutine(coroutine, coroutine)
 }
 

Original file line number	Diff line number	Diff line change
`@@ -43,7 +43,7 @@ fun <T> mono(`
`43`	`43`	`val newContext = newCoroutineContext(context)`
`44`	`44`	`val coroutine = MonoCoroutine(newContext, sink)`
`45`	`45`	`coroutine.initParentJob(context[Job])`
`46`		`- sink.setCancellation(coroutine)`
	`46`	`+ sink.onDispose(coroutine)`
`47`	`47`	`block.startCoroutine(coroutine, coroutine)`
`48`	`48`	`}`
`49`	`49`