Skip to content

Commit f4a997e

Browse files
committed
add hasNext method
1 parent 9910908 commit f4a997e

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

src/execution/execute.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -350,7 +350,7 @@ function executeImpl(
350350
(data) => {
351351
const initialResult = buildResponse(data, exeContext.errors);
352352
const publisher = exeContext.publisher;
353-
if (publisher.subsequentPayloads.size > 0) {
353+
if (publisher.hasNext()) {
354354
return {
355355
initialResult: {
356356
...initialResult,
@@ -369,7 +369,7 @@ function executeImpl(
369369
}
370370
const initialResult = buildResponse(result, exeContext.errors);
371371
const publisher = exeContext.publisher;
372-
if (publisher.subsequentPayloads.size > 0) {
372+
if (publisher.hasNext()) {
373373
return {
374374
initialResult: {
375375
...initialResult,

src/execution/publisher.ts

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,10 @@ export class Publisher {
3232
this.subsequentPayloads.add(payload);
3333
}
3434

35+
hasNext(): boolean {
36+
return this.subsequentPayloads.size > 0;
37+
}
38+
3539
filter(predicate: (payload: AsyncPayloadRecord) => boolean): void {
3640
this.subsequentPayloads.forEach((asyncRecord) => {
3741
if (predicate(asyncRecord)) {

0 commit comments

Comments
 (0)