Skip to content

Commit cfedc4c

Browse files
committed
feat(subscribe): allow providing custom execute function for subscribe
1 parent 1af561f commit cfedc4c

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

src/subscription/subscribe.d.ts

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import { Maybe } from '../jsutils/Maybe';
22

33
import { DocumentNode } from '../language/ast';
4-
import { ExecutionResult } from '../execution/execute';
4+
import { execute, ExecutionResult } from '../execution/execute';
55
import { GraphQLSchema } from '../type/schema';
66
import { GraphQLFieldResolver } from '../type/definition';
77

@@ -14,6 +14,7 @@ export interface SubscriptionArgs {
1414
operationName?: Maybe<string>;
1515
fieldResolver?: Maybe<GraphQLFieldResolver<any, any>>;
1616
subscribeFieldResolver?: Maybe<GraphQLFieldResolver<any, any>>;
17+
execute?: Maybe<typeof execute>
1718
}
1819

1920
/**

src/subscription/subscribe.js

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ import {
1414
buildExecutionContext,
1515
buildResolveInfo,
1616
collectFields,
17-
execute,
17+
execute as defaultExecute,
1818
getFieldDef,
1919
} from '../execution/execute';
2020

@@ -34,6 +34,7 @@ export type SubscriptionArgs = {|
3434
operationName?: ?string,
3535
fieldResolver?: ?GraphQLFieldResolver<any, any>,
3636
subscribeFieldResolver?: ?GraphQLFieldResolver<any, any>,
37+
execute?: ?typeof execute
3738
|};
3839

3940
/**
@@ -69,6 +70,7 @@ export async function subscribe(
6970
operationName,
7071
fieldResolver,
7172
subscribeFieldResolver,
73+
execute = defaultExecute
7274
} = args;
7375

7476
// $FlowFixMe[incompatible-call]

0 commit comments

Comments
 (0)