NotificationApiV13

internal open class NotificationApiV13(authenticatedNetworkClient: AuthenticatedNetworkClient, authenticatedWebSocketClient: AuthenticatedWebSocketClient, serverLinks: ServerConfigDTO.Links) : NotificationApiV12

Constructors

internal constructor(authenticatedNetworkClient: AuthenticatedNetworkClient, authenticatedWebSocketClient: AuthenticatedWebSocketClient, serverLinks: ServerConfigDTO.Links)

val mutex: Mutex

val serverLinks: ServerConfigDTO.Links

open suspend override fun acknowledgeEvents(clientId: String, markerId: String, eventAcknowledgeRequest: EventAcknowledgeRequest)

open suspend override fun consumeLiveEvents(clientId: String, markerId: String): NetworkResponse<Flow<WebSocketEvent<ConsumableNotificationResponse>>>

Open a websocket connection to listen to live events.

open suspend override fun getAllNotifications(querySize: Int, queryClient: String): NetworkResponse<NotificationResponse>

request Notifications from the beginning of time

open fun getApiNotSupportedError(apiName: String, apiVersion: Int): NetworkResponse.Error

open suspend override fun ~~listenToLiveEvents~~(clientId: String): NetworkResponse<Flow<WebSocketEvent<EventResponseToStore>>>

open suspend override fun mostRecentNotification(queryClient: String): NetworkResponse<EventResponse>

open suspend override fun notificationsByBatch(querySize: Int, queryClient: String, querySince: String): NetworkResponse<NotificationResponse>

open suspend override fun oldestNotification(queryClient: String): NetworkResponse<EventResponseToStore>