queue/io.neuralheads.kmpworker.queue/OfflineQueue

OfflineQueue

class OfflineQueue(worker: KmpWorker, repository: TaskRepository, networkMonitor: NetworkMonitor)

Offline-first task queue that persists tasks when the device is offline and automatically replays them when connectivity is restored.

Flow:

enqueue(request)
     ↓
isOnline?
     ↓ YES → execute immediately via KmpWorker
     ↓ NO  → persist to TaskRepository (status = PENDING)
             ↓
        network restored
             ↓
        replay() → re-enqueue all PENDING tasks

Recovery on app restart: Pending tasks survive app termination because they are persisted to SQLDelight. On next app start, call replay manually or ensure start is called so the queue can re-enqueue them.

Usage:

val queue = OfflineQueue(kmpWorker, repository, networkMonitor)
queue.start()

queue.enqueue(myTaskRequest)

Constructors

OfflineQueue

constructor(worker: KmpWorker, repository: TaskRepository, networkMonitor: NetworkMonitor)

Functions

enqueue

suspend fun enqueue(request: TaskRequest)

Enqueues a task request.

pendingCount

suspend fun pendingCount(): Int

Returns the number of tasks currently pending in the offline queue. A task is counted if its status is PENDING or RUNNING.

replay

suspend fun replay()

Manually triggers replay of all pending tasks from the database.

start

fun start()

Starts the offline queue.

stop

fun stop()

Stops the coroutine scope. Call in cleanup/onDestroy if needed.