1 | import Observable from 'zen-observable-ts';
|
2 | import { PubSubProvider, PubSubOptions, ProvidertOptions } 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 | private getProviderByName;
|
42 | private getProviders;
|
43 | publish(topics: string[] | string, msg: any, options?: ProvidertOptions): Promise<void[]>;
|
44 | subscribe(topics: string[] | string, options?: ProvidertOptions): Observable<any>;
|
45 | }
|
46 | export declare const PubSub: PubSubClass;
|