Class IgpapiRealtime

Hierarchy

IgpapiRealtime

Index

Constructors

Properties

#subscription? $ direct facade graphql iris live mqtt safeDisconnect strategy subject subscriptions topic

Methods

connect disconnect setupListeners

Constructors

constructor

new IgpapiRealtime(facade: IgpapiFacade, strategy: RealtimeMqttStrategy, mqtt: RealtimeMqttManager, subject: RealtimeSubject, subscriptions: SubscriptionManager, graphql: IgpapiRealtimeGraphqlQuery, iris: Iris, topic: RealtimeTopic, direct: RealtimeDirect): IgpapiRealtime
Parameters
- facade: IgpapiFacade
- strategy: RealtimeMqttStrategy
- mqtt: RealtimeMqttManager
- subject: RealtimeSubject
- subscriptions: SubscriptionManager
- graphql: IgpapiRealtimeGraphqlQuery
- iris: Iris
- topic: RealtimeTopic
- direct: RealtimeDirect
Returns IgpapiRealtime

Properties

`Private` `Optional` #subscription

#subscription?: Subscription

$

$: Observable<RealtimeMessage<any>> = ...

Global event bus.

`Readonly` direct

direct: RealtimeDirect

`Private` `Readonly` facade

facade: IgpapiFacade

`Readonly` graphql

graphql: IgpapiRealtimeGraphqlQuery

`Readonly` iris

iris: Iris

live

live: ((input: IgpapiRealtimeLiveInput) => IgpapiRealtimeLive) = ...

Type declaration

- (input: IgpapiRealtimeLiveInput): IgpapiRealtimeLive
- Parameters
  - input: IgpapiRealtimeLiveInput
  Returns IgpapiRealtimeLive

`Readonly` mqtt

mqtt: RealtimeMqttManager

`Private` safeDisconnect

safeDisconnect: boolean = false

`Private` `Readonly` strategy

strategy: RealtimeMqttStrategy

`Private` `Readonly` subject

subject: RealtimeSubject

`Readonly` subscriptions

subscriptions: SubscriptionManager

`Readonly` topic

topic: RealtimeTopic

Methods

connect

connect(): Promise<void>
Returns Promise<void>

disconnect

disconnect(): Promise<any>
Returns Promise<any>

`Protected` setupListeners

setupListeners(): void
Returns void