RoomSubmitOutbox

class RoomSubmitOutbox<T : Any>(dao: SubmitDraftDao, json: Json, serializer: KSerializer<T>) : SubmitOutbox<T>

Constructors

constructor(dao: SubmitDraftDao, json: Json, serializer: KSerializer<T>)

open suspend override fun clear(formKey: String)

Remove all drafts for formKey.

open override fun drafts(formKey: String): Flow<List<DraftEntry<T>>>

All drafts for formKey, ordered newest-first.

open suspend override fun enqueue(formKey: String, uniqueKey: String, payload: T)

Idempotent upsert by (formKey, uniqueKey). Resets to PENDING if not yet SUBMITTED.

open suspend override fun markFailed(formKey: String, uniqueKey: String, error: String)

Mark FAILED with an error message; caller may retry later.

open suspend override fun markSubmitted(formKey: String, uniqueKey: String)

Mark SUBMITTED after a successful sync.