| 1 | import { Observable } from 'rxjs';
|
| 2 | import { PubSubBase, PubSubContent, PubSubOptions, PublishInput, SubscribeInput } from '../types/PubSub';
|
| 3 | export declare abstract class AbstractPubSub<T extends PubSubOptions> implements PubSubBase {
|
| 4 | private _config;
|
| 5 | constructor(options: T);
|
| 6 | configure(config: T): T;
|
| 7 | protected get options(): T;
|
| 8 | abstract newClient(clientOptions: T): Promise<any>;
|
| 9 | abstract publish(input: PublishInput): void;
|
| 10 | abstract subscribe(input: SubscribeInput): Observable<PubSubContent>;
|
| 11 | }
|