File tree Expand file tree Collapse file tree 2 files changed +6
-2
lines changed
Expand file tree Collapse file tree 2 files changed +6
-2
lines changed Original file line number Diff line number Diff 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 ,
Original file line number Diff line number Diff 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 ) ) {
You can’t perform that action at this time.
0 commit comments