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 126126 "license" : " Apache-2.0" ,
127127 "files" : [
128128 " 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"
130134 ],
131135 "dependencies" : {
132136 "@firebase/component" : " 0.7.0" ,
Original file line number Diff line number Diff line change @@ -262,17 +262,20 @@ export async function invokeExecutePipeline(
262262 executePipelineRequest
263263 ) ;
264264
265- return response
265+ const result : PipelineStreamElement [ ] = [ ] ;
266+ response
266267 . filter ( proto => ! ! proto . results )
267- . flatMap ( proto => {
268+ . forEach ( proto => {
268269 if ( proto . results ! . length === 0 ) {
269- return fromPipelineResponse ( datastoreImpl . serializer , proto ) ;
270+ result . push ( fromPipelineResponse ( datastoreImpl . serializer , proto ) ) ;
270271 } 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 ) )
273274 ) ;
274275 }
275276 } ) ;
277+
278+ return result ;
276279}
277280
278281export async function invokeRunQueryRpc (
You can’t perform that action at this time.
0 commit comments