1 | import { GraphQLSchema, GraphQLError } from 'graphql';
|
2 | export declare class FilteredPubSub {
|
3 | private ee;
|
4 | private subscriptions;
|
5 | private subIdCounter;
|
6 | constructor();
|
7 | publish(triggerName: string, payload: any): void;
|
8 | subscribe(triggerName: string, filterFunc: Function, handler: Function): number;
|
9 | unsubscribe(subId: number): void;
|
10 | }
|
11 | export declare class ValidationError extends Error {
|
12 | errors: Array<GraphQLError>;
|
13 | message: string;
|
14 | constructor(errors: any);
|
15 | }
|
16 | export interface SubscriptionOptions {
|
17 | query: string;
|
18 | operationName: string;
|
19 | callback: Function;
|
20 | variables?: {
|
21 | [key: string]: any;
|
22 | };
|
23 | context?: any;
|
24 | formatError?: Function;
|
25 | formatResponse?: Function;
|
26 | }
|
27 | export declare class SubscriptionManager {
|
28 | private pubsub;
|
29 | private schema;
|
30 | private setupFunctions;
|
31 | private subscriptions;
|
32 | private maxSubscriptionId;
|
33 | constructor(options: {
|
34 | schema: GraphQLSchema;
|
35 | setupFunctions: {
|
36 | [subscriptionName: string]: Function;
|
37 | };
|
38 | });
|
39 | publish(triggerName: string, payload: any): void;
|
40 | subscribe(options: SubscriptionOptions): number;
|
41 | unsubscribe(subId: any): void;
|
42 | }
|