Skip to content

Commit 3ae1a2e

Browse files
committed
refactor: move execution utils to execution folder
the Publisher and Bundler abstractions are such core parts of the execution algorithm that they probably belong within the execution folder (following the pattern of the map/flatten asyncIterable helpers)
1 parent 6dc55f5 commit 3ae1a2e

7 files changed

Lines changed: 5 additions & 5 deletions

File tree

File renamed without changes.
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
import type { Maybe } from './Maybe';
1+
import type { Maybe } from '../jsutils/Maybe';
22

33
export interface IBundler<TDataResult, TErrorResult> {
44
queueData: (index: number, result: TDataResult) => void;

src/execution/executor.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -52,9 +52,6 @@ import { addPath, pathToArray } from '../jsutils/Path';
5252
import { isAsyncIterable } from '../jsutils/isAsyncIterable';
5353
import { isIterableObject } from '../jsutils/isIterableObject';
5454
import { resolveAfterAll } from '../jsutils/resolveAfterAll';
55-
import { Publisher } from '../jsutils/publisher';
56-
import { Bundler } from '../jsutils/bundler';
57-
import { getSequentialBundler } from '../jsutils/getSequentialBundler';
5855
import { toError } from '../jsutils/toError';
5956

6057
import type { ExecutorSchema } from './executorSchema';
@@ -64,6 +61,9 @@ import {
6461
getArgumentValues,
6562
getDirectiveValues,
6663
} from './values';
64+
import { Publisher } from './publisher';
65+
import { Bundler } from './bundler';
66+
import { getSequentialBundler } from './getSequentialBundler';
6767
import { mapAsyncIterable } from './mapAsyncIterable';
6868
import { flattenAsyncIterable } from './flattenAsyncIterable';
6969

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
import { Repeater } from './repeater';
1+
import { Repeater } from '../jsutils/repeater';
22

33
interface PublisherOptions<TSource, TPayload> {
44
payloadFromSource?: (source: TSource, hasNext: boolean) => TPayload;

0 commit comments

Comments
 (0)