1 | import Observable from 'zen-observable-ts';
|
2 | import { ProvidertOptions } from '../types';
|
3 | import { AbstractPubSubProvider } from './PubSubProvider';
|
4 | export declare class AWSAppSyncRealTimeProvider extends AbstractPubSubProvider {
|
5 | private awsRealTimeSocket;
|
6 | private socketStatus;
|
7 | private keepAliveTimeoutId;
|
8 | private keepAliveTimeout;
|
9 | private subscriptionObserverMap;
|
10 | private promiseArray;
|
11 | getProviderName(): string;
|
12 | newClient(): Promise<any>;
|
13 | publish(_topics: string[] | string, _msg: any, _options?: any): Promise<void>;
|
14 | subscribe(_topics: string[] | string, options?: ProvidertOptions): Observable<any>;
|
15 | protected readonly isSSLEnabled: boolean;
|
16 | private _startSubscriptionWithAWSAppSyncRealTime;
|
17 | private _waitForSubscriptionToBeConnected;
|
18 | private _sendUnsubscriptionMessage;
|
19 | private _removeSubscriptionObserver;
|
20 | private _closeSocketIfRequired;
|
21 | private _handleIncomingSubscriptionMessage;
|
22 | private _errorDisconnect;
|
23 | private _timeoutStartSubscriptionAck;
|
24 | private _initializeWebSocketConnection;
|
25 | private _initializeRetryableHandshake;
|
26 | private _initializeHandshake;
|
27 | private _awsRealTimeHeaderBasedAuth;
|
28 | private _awsRealTimeCUPHeader;
|
29 | private _awsRealTimeOPENIDHeader;
|
30 | private _awsRealTimeApiKeyHeader;
|
31 | private _awsRealTimeIAMHeader;
|
32 | |
33 |
|
34 |
|
35 | _ensureCredentials(): any;
|
36 | }
|