EventDataSource
class EventDataSource(notificationApi: <Error class: unknown class>, metadataDAO: <Error class: unknown class>, currentClientId: CurrentClientIdProvider, selfUserId: <Error class: unknown class>, eventMapper: EventMapper = MapperProvider.eventMapper(selfUserId)) : EventRepository
Constructors
Link copied to clipboard
constructor(notificationApi: <Error class: unknown class>, metadataDAO: <Error class: unknown class>, currentClientId: CurrentClientIdProvider, selfUserId: <Error class: unknown class>, eventMapper: EventMapper = MapperProvider.eventMapper(selfUserId))
Functions
Link copied to clipboard
open suspend override fun clearLastProcessedEventId(): <Error class: unknown class><<Error class: unknown class>, Unit>
Clears the last processed event ID.
Link copied to clipboard
open suspend override fun fetchMostRecentEventId(): <Error class: unknown class><<Error class: unknown class>, String>
Link copied to clipboard
open suspend override fun fetchOldestAvailableEventId(): <Error class: unknown class><<Error class: unknown class>, String>
Fetches the oldest available event ID from remote.
Link copied to clipboard
Link copied to clipboard
open suspend override fun lastProcessedEventId(): <Error class: unknown class><<Error class: unknown class>, String>
Retrieves the last processed event ID from the storage.
Link copied to clipboard
open suspend override fun liveEvents(): <Error class: unknown class><<Error class: unknown class>, <Error class: unknown class><<Error class: unknown class><EventEnvelope>>>
Link copied to clipboard
Parse events from an external JSON payload
Link copied to clipboard
open suspend override fun pendingEvents(): <Error class: unknown class><<Error class: unknown class><<Error class: unknown class>, EventEnvelope>>
Link copied to clipboard