File tree Expand file tree Collapse file tree 2 files changed +13
-6
lines changed Expand file tree Collapse file tree 2 files changed +13
-6
lines changed Original file line number Diff line number Diff line change 126
126
"license" : " Apache-2.0" ,
127
127
"files" : [
128
128
" dist" ,
129
- " lite/package.json"
129
+ " lite/package.json" ,
130
+ " pipelines/package.json" ,
131
+ " pipelines/pipelines.d.ts" ,
132
+ " lite/pipelines/package.json" ,
133
+ " lite/pipelines/pipelines.d.ts"
130
134
],
131
135
"dependencies" : {
132
136
"@firebase/component" : " 0.7.0" ,
Original file line number Diff line number Diff line change @@ -262,17 +262,20 @@ export async function invokeExecutePipeline(
262
262
executePipelineRequest
263
263
) ;
264
264
265
- return response
265
+ const result : PipelineStreamElement [ ] = [ ] ;
266
+ response
266
267
. filter ( proto => ! ! proto . results )
267
- . flatMap ( proto => {
268
+ . forEach ( proto => {
268
269
if ( proto . results ! . length === 0 ) {
269
- return fromPipelineResponse ( datastoreImpl . serializer , proto ) ;
270
+ result . push ( fromPipelineResponse ( datastoreImpl . serializer , proto ) ) ;
270
271
} else {
271
- return proto . results ! . map ( result =>
272
- fromPipelineResponse ( datastoreImpl . serializer , proto , result )
272
+ return proto . results ! . forEach ( document =>
273
+ result . push ( fromPipelineResponse ( datastoreImpl . serializer , proto , document ) )
273
274
) ;
274
275
}
275
276
} ) ;
277
+
278
+ return result ;
276
279
}
277
280
278
281
export async function invokeRunQueryRpc (
You can’t perform that action at this time.
0 commit comments