MessageTimelineSession
class MessageTimelineSession(queries: MessageTimelineQueries, driver: SqlDriver, readDispatcher: ReadDispatcher, cursorScope: Any, conversationId: ConversationIDEntity, includeDeleted: Boolean, onInvalidated: () -> Unit) : AutoCloseable, Query.Listener
One invalidatable read generation. Register before loading and close when the consumer leaves.
Constructors
Link copied to clipboard
internal constructor(queries: MessageTimelineQueries, driver: SqlDriver, readDispatcher: ReadDispatcher, cursorScope: Any, conversationId: ConversationIDEntity, includeDeleted: Boolean, onInvalidated: () -> Unit)
Functions
Link copied to clipboard
suspend fun load(request: MessageTimelineRequestEntity, limit: Int): MessageTimelineLoadResultEntity
Limits are positive and capped at 100. Cancellation from the caller always propagates.
Link copied to clipboard