UNPKG

1.21 kBTypeScriptView Raw
1import { GraphQLSchema, GraphQLError } from 'graphql';
2export 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}
11export declare class ValidationError extends Error {
12 errors: Array<GraphQLError>;
13 message: string;
14 constructor(errors: any);
15}
16export 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}
27export 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}