File tree Expand file tree Collapse file tree 1 file changed +3
-26
lines changed Expand file tree Collapse file tree 1 file changed +3
-26
lines changed Original file line number Diff line number Diff line change @@ -2195,44 +2195,21 @@ async function getNextAsyncStreamItemsResult(
2195
2195
itemType ,
2196
2196
) ;
2197
2197
2198
- const nextStreamItems : StreamItemsRecord = nextAsyncStreamItems (
2199
- streamRecord ,
2200
- path ,
2201
- index ,
2202
- asyncIterator ,
2203
- exeContext ,
2204
- fieldGroup ,
2205
- info ,
2206
- itemType ,
2207
- ) ;
2208
-
2209
- return prependNextStreamItems ( result , nextStreamItems ) ;
2210
- }
2211
-
2212
- function nextAsyncStreamItems (
2213
- streamRecord : SubsequentResultRecord ,
2214
- path : Path ,
2215
- initialIndex : number ,
2216
- asyncIterator : AsyncIterator < unknown > ,
2217
- exeContext : ExecutionContext ,
2218
- fieldGroup : FieldGroup ,
2219
- info : GraphQLResolveInfo ,
2220
- itemType : GraphQLOutputType ,
2221
- ) : StreamItemsRecord {
2222
2198
const nextStreamItems : StreamItemsRecord = {
2223
2199
streamRecord,
2224
2200
result : getNextAsyncStreamItemsResult (
2225
2201
streamRecord ,
2226
2202
path ,
2227
- initialIndex + 1 ,
2203
+ index ,
2228
2204
asyncIterator ,
2229
2205
exeContext ,
2230
2206
fieldGroup ,
2231
2207
info ,
2232
2208
itemType ,
2233
2209
) ,
2234
2210
} ;
2235
- return nextStreamItems ;
2211
+
2212
+ return prependNextStreamItems ( result , nextStreamItems ) ;
2236
2213
}
2237
2214
2238
2215
function completeStreamItems (
You can’t perform that action at this time.
0 commit comments