1 | import Observable from 'zen-observable-ts';
|
2 | import { PubSubProvider, PubSubOptions, ProviderOptions } from './types';
|
3 | export declare class PubSubClass {
|
4 | private _options;
|
5 | private _pluggables;
|
6 | |
7 |
|
8 |
|
9 | private _awsAppSyncProvider?;
|
10 | |
11 |
|
12 |
|
13 | private _awsAppSyncRealTimeProvider?;
|
14 | |
15 |
|
16 |
|
17 | private get awsAppSyncProvider();
|
18 | |
19 |
|
20 |
|
21 | private get awsAppSyncRealTimeProvider();
|
22 | |
23 |
|
24 |
|
25 |
|
26 |
|
27 | constructor(options?: PubSubOptions);
|
28 | getModuleName(): string;
|
29 | /**
|
30 | * Configure PubSub part with configurations
|
31 | *
|
32 | * @param {PubSubOptions} config - Configuration for PubSub
|
33 | * @return {Object} - The current configuration
|
34 | */
|
35 | configure(options: PubSubOptions): PubSubOptions;
|
36 | |
37 |
|
38 |
|
39 |
|
40 | addPluggable(pluggable: PubSubProvider): Promise<object>;
|
41 | |
42 |
|
43 |
|
44 |
|
45 | removePluggable(providerName: string): void;
|
46 | private getProviderByName;
|
47 | private getProviders;
|
48 | publish(topics: string[] | string, msg: any, options?: ProviderOptions): Promise<void[]>;
|
49 | subscribe(topics: string[] | string, options?: ProviderOptions): Observable<any>;
|
50 | }
|
51 | export declare const PubSub: PubSubClass;
|