Class AWSAppSyncProvider

Hierarchy

MqttOverWSProvider
- AWSAppSyncProvider

Implements

any

Index

Constructors

constructor

Properties

_topicObservers

Accessors

Methods

Constructors

constructor

new AWSAppSyncProvider(options?: MqttProvidertOptions): AWSAppSyncProvider

Inherited from MqttOverWSProvider.constructor

Overrides AbstractPubSubProvider.constructor
- Defined in pubsub/src/Providers/MqttOverWSProvider.ts:55
Parameters
- Default value options: MqttProvidertOptions = {}
Returns AWSAppSyncProvider

Properties

Protected _topicObservers

_topicObservers: Map<string, Set<SubscriptionObserver<any>>> = new Map()

Accessors

Protected clientId

get clientId(): any

Inherited from MqttOverWSProvider.clientId
- Defined in pubsub/src/Providers/MqttOverWSProvider.ts:61
Returns any

Protected clientsQueue

get clientsQueue(): ClientsQueue

Inherited from MqttOverWSProvider.clientsQueue
- Defined in pubsub/src/Providers/MqttOverWSProvider.ts:65
Returns ClientsQueue

Protected endpoint

get endpoint(): void

Overrides MqttOverWSProvider.endpoint
- Defined in pubsub/src/Providers/AWSAppSyncProvider.ts:23
Returns void

Protected options

get options(): ProvidertOptions

Inherited from AbstractPubSubProvider.options
- Defined in pubsub/src/Providers/PubSubProvider.ts:39
Returns ProvidertOptions

Methods

configure

configure(config?: ProvidertOptions): ProvidertOptions

Inherited from AbstractPubSubProvider.configure
- Defined in pubsub/src/Providers/PubSubProvider.ts:27
Parameters
- Default value config: ProvidertOptions = {}
Returns ProvidertOptions

Protected connect

connect(clientId: string, options?: MqttProvidertOptions): Promise<Paho.Client>

Inherited from MqttOverWSProvider.connect
- Defined in pubsub/src/Providers/MqttOverWSProvider.ts:101
Parameters
- clientId: string
- Default value options: MqttProvidertOptions = {}
Returns Promise<Paho.Client>

Protected disconnect

disconnect(clientId: string): Promise<void>

Overrides MqttOverWSProvider.disconnect
- Defined in pubsub/src/Providers/AWSAppSyncProvider.ts:74
Parameters
- clientId: string
Returns Promise<void>

getCategory

getCategory(): string

Inherited from AbstractPubSubProvider.getCategory
- Defined in pubsub/src/Providers/PubSubProvider.ts:35
Returns string

getProviderName

getProviderName(): string

Overrides MqttOverWSProvider.getProviderName
- Defined in pubsub/src/Providers/AWSAppSyncProvider.ts:25
Returns string

Protected getTopicForValue

getTopicForValue(value: any): any

Inherited from MqttOverWSProvider.getTopicForValue
- Defined in pubsub/src/Providers/MqttOverWSProvider.ts:67
Parameters
- value: any
Returns any

newClient

newClient(__namedParameters: object): Promise<Paho.Client>

Inherited from MqttOverWSProvider.newClient

Overrides AbstractPubSubProvider.newClient
- Defined in pubsub/src/Providers/MqttOverWSProvider.ts:77
Parameters
- __namedParameters: object
  - clientId: string
  - url: string
Returns Promise<Paho.Client>

onDisconnect

onDisconnect(__namedParameters: object): void

Overrides MqttOverWSProvider.onDisconnect
- Defined in pubsub/src/Providers/AWSAppSyncProvider.ts:50
Parameters
- __namedParameters: object
  - args: args
  - clientId: any
  - errorCode: any
Returns void

publish

publish(topics: string[] | string, msg: any, options?: any): Promise<void>

Overrides MqttOverWSProvider.publish
- Defined in pubsub/src/Providers/AWSAppSyncProvider.ts:27
Parameters
- topics: string[] | string
- msg: any
- Optional options: any
Returns Promise<void>

subscribe

subscribe(topics: string[] | string, options?: any): Observable<any>

Overrides MqttOverWSProvider.subscribe
- Defined in pubsub/src/Providers/AWSAppSyncProvider.ts:82
Parameters
- topics: string[] | string
- Default value options: any = {}
Returns Observable<any>