TaskScheduler

Internal scheduling abstraction used by platform implementations.

Extends KmpWorker with no additional API surface — exists as a named type so platform modules can implement a single, focused contract.

enqueueChain and observeChain are intentionally NOT implemented here — they are handled at the KmpWorker layer (AndroidKmpWorker / IOSKmpWorker).

Platform implementations:

Functions

abstract suspend override fun cancel(taskId: String)

open suspend fun cancelBatch(taskIds: List<String>)

abstract suspend override fun cancelByTag(tag: String)

abstract suspend override fun enqueue(request: TaskRequest)

open suspend fun enqueueBatch(requests: List<TaskRequest>)

open suspend fun enqueueChain(chain: TaskChain)

open suspend override fun enqueueChain(chain: TaskChain, policy: ChainPolicy): Nothing

abstract override fun observe(taskId: String): Flow<TaskState>

abstract override fun observeAll(): Flow<Pair<String, TaskState>>

open override fun observeChain(chainId: String): Flow<TaskState>

abstract override fun register(taskId: String, block: suspend () -> Unit)

abstract override fun registerWithContext(taskId: String, block: suspend TaskExecutionContext.() -> Unit)