Meshtastic App/com.geeksville.mesh.concurrent

Package-level declarations

Types

CallbackContinuation

class CallbackContinuation<in T>(cb: (Result<T>) -> Unit) : Continuation<T>

An async continuation that just calls a callback when the result is available

Continuation

interface Continuation<in T> : Logging

A deferred execution object (with various possible implementations)

DeferredExecution

class DeferredExecution : Logging

Sometimes when starting services we face situations where messages come in that require computation but we can't do that computation yet because we are still waiting for some long running init to complete.

SyncContinuation

class SyncContinuation<T> : Continuation<T>

This is a blocking/threaded version of coroutine Continuation

Functions

handledLaunch

fun CoroutineScope.handledLaunch(context: CoroutineContext = EmptyCoroutineContext, start: CoroutineStart = CoroutineStart.DEFAULT, block: suspend CoroutineScope.() -> Unit): Job

suspend

fun <T> suspend(timeoutMsecs: Long = -1, initfn: (SyncContinuation<T>) -> Unit): T

Calls an init function which is responsible for saving our continuation so that some other thread can call resume or resume with exception.