TelemetrySubscriber class

Constructors

TelemetrySubscriber(TelemetryService telemetryService, List<WebsocketCmd> subscriptionCommands)

Properties

alarmDataStream → Stream<AlarmDataUpdate>

no setter

attributeDataStream → Stream<List<AttributeData>>

no setter

dataStream → Stream<SubscriptionUpdate>

no setter

entityCountStream → Stream<EntityCountUpdate>

no setter

entityDataStream → Stream<EntityDataUpdate>

no setter

hashCode → int

The hash code for this object.

no setter, inherited

lastUpdatedNotification ↔ NotificationsUpdate?

getter/setter pair

notificationCountStream → Stream<NotificationCountUpdate>

no setter

notificationStream → Stream<NotificationsUpdate>

no setter

reconnectStream → Stream<void>

no setter

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

subscriptionCommands → List<WebsocketCmd>

no setter

Methods

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

onCmdUpdate(CmdUpdate message) → void

onData(SubscriptionUpdate message) → void

onReconnected() → void

setTsOffset(int tsOffset) → bool

subscribe() → void

toString() → String

A string representation of this object.

inherited

unsubscribe() → void

update() → void

Operators

operator ==(Object other) → bool

The equality operator.

inherited

Static Methods

createEntityAttributesSubscription({required TelemetryService telemetryService, required EntityId entityId, required String attributeScope, List<String>? keys}) → TelemetrySubscriber

createMarkAllAsReadCommand({required TelemetryService telemetryService}) → TelemetrySubscriber

createMarkAsReadCommand({required TelemetryService telemetryService, required List<String> notifications}) → TelemetrySubscriber

createNotificationCountSubscription({required TelemetryService telemetryService}) → TelemetrySubscriber

createNotificationsSubscription({required TelemetryService telemetryService, int limit = 10}) → TelemetrySubscriber