RxExecutor.launch lets a user run suspend functions within that executor.

nedtwigg · nedtwigg · commit 1ae40060d10e · 2025-01-31T18:08:02.000-08:00
diff --git a/src/main/java/com/diffplug/common/rx/RxExecutor.kt b/src/main/java/com/diffplug/common/rx/RxExecutor.kt
@@ -36,6 +36,9 @@ import kotlinx.coroutines.launch
 class RxExecutor internal constructor(val executor: Executor, val dispatcher: CoroutineDispatcher) :
 		RxSubscriber {
 
+	fun launch(block: suspend CoroutineScope.() -> Unit): Job =
+			CoroutineScope(Job() + dispatcher).launch(block = block)
+
 	interface Has : Executor {
 		val rxExecutor: RxExecutor
 	}

Original file line number	Diff line number	Diff line change
`@@ -36,6 +36,9 @@ import kotlinx.coroutines.launch`
`36`	`36`	`class RxExecutor internal constructor(val executor: Executor, val dispatcher: CoroutineDispatcher) :`
`37`	`37`	`RxSubscriber {`
`38`	`38`
	`39`	`+ fun launch(block: suspend CoroutineScope.() -> Unit): Job =`
	`40`	`+ CoroutineScope(Job() + dispatcher).launch(block = block)`
	`41`	`+`
`39`	`42`	`interface Has : Executor {`
`40`	`43`	`val rxExecutor: RxExecutor`
`41`	`44`	`}`