Skip to content

Commit 743f53e

Browse files
committed
add hasNext method
1 parent 4dbdc64 commit 743f53e

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
@@ -359,7 +359,7 @@ function executeImpl(
359359
(data) => {
360360
const initialResult = buildResponse(data, exeContext.errors);
361361
const publisher = exeContext.publisher;
362-
if (publisher.subsequentPayloads.size > 0) {
362+
if (publisher.hasNext()) {
363363
return {
364364
initialResult: {
365365
...initialResult,
@@ -378,7 +378,7 @@ function executeImpl(
378378
}
379379
const initialResult = buildResponse(result, exeContext.errors);
380380
const publisher = exeContext.publisher;
381-
if (publisher.subsequentPayloads.size > 0) {
381+
if (publisher.hasNext()) {
382382
return {
383383
initialResult: {
384384
...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)