element.call() {
   service.run() {
      element2.call() { ... }
   }
}

suspendCoroutine

...
element.call() // suspends until it is done.
service.run() // suspends until it is done.
element2.call() // suspends until it is done
...

...
val result = element.call() // suspends until it is done.
val runResut = service.run() // suspends until it is done.
val result2 = element2.call() // suspends until it is done
...

suspend fun Element.call_() = suspendCancelableCoroutine { cont -> call() { cont.resume(it } }

suspend fun Service.run_() = suspendCancelableCoroutine { cont -> run() { cont.resume(it) } }

...

scope.launch {
    val result = element.call_() // suspends until it is done.
    val runResut = service.run_() // suspends until it is done.
    val result2 = element2.call_() // suspends until it is done
}

_

scope

scope

result2

element.call()

Dispatchers.Unconfined

val scope = Dispatchers.Unconfined + parentJob
scope.launch {
    // Invoked on calling thread.
    val result = element.call_()
    // Invoked on whatever thread invoked the first callback.
    val runResult = service.run_()
    // Invoked on whatever thread invoked the second callback.
    val result2 = element2.call_()
    // Calling function will resume on whatever thread invoked the third callback.
}

runBlocking

Unconfined

val scope = CoroutineScope(Dispatchers.Unconfined)
scope.launch(start = CoroutineStart.UNDISPATCHED) {
    ... code here
}

runBlocking { launch(Dispatchers.Unconfined) {

CoroutineScope(Dispatchers.Unconfined).launch(start = CoroutineStart.UNDISPATCHED)

CoroutineStart.UNDISPATCHED

Unconfined

run

call

Then you have to assume that the callbacks (the lambdas of

run

and

call

) will never be called on another thread.

every element or service is invoking callback on proper thread already

i can’t suspend current thread

every call shouldn’t block its own thread, i.e. each callback should exit after invoking next element/service (i can’t use

suspendCoroutine

because of that)

just wasnt using them in proper context

CoroutineScope(Dispatchers.Unconfined).launch