MessageReader

A sequential reader. Close it when finished. Reading a cursor does not acknowledge a message.

Functions

open override fun close()

Rejects the last item and closes native ownership before returning.

Uses the direct Flow collector boundary. App-added buffering changes that boundary.

Acknowledges the last returned item, then returns the next item. Cancellation closes this reader.

fun updateFilter(type: Conversations.ConversationFilterType = ConversationFilterType.ALL, consentStates: List<ConsentState>? = null)

Null selects all groups. An empty list selects no groups. This does not rewind delivery.