angular – 如何从Observable.from中收集发射值数组？

return Observable.from(input_array)
           .concatMap((item)=>{
               //this part emits an Observable.of<String> for each item in the input_array
           })
           .scan((output_array:string[],each_item_output_array:string)=>{
               return output_array.push(each_item_output_array) ;
           });

在您对 scan的调用中,您没有为累加器指定种子.在那种情况下,第一个值用作种子.例如：

Rx.observable
  .from(["a","b","c"])
  .scan((acc,value) => acc + value)
  .subscribe(value => console.log(value));

<script src="https://unpkg.com/rxjs@5/bundles/Rx.min.js"></script>

在您的代码段中,第一个值不是数组,因此您无法调用push.要将值累积到数组中,可以指定如下的数组种子：

Rx.observable
  .from(["a","c"])
  .concatMap(value => Rx.observable.of(value))
  .scan((acc,value) => {
    acc.push(value);
    return acc;
  },[]) // Note that an empty array is use as the seed
  .subscribe(value => console.log(JSON.Stringify(value)));

<script src="https://unpkg.com/rxjs@5/bundles/Rx.min.js"></script>

虽然,对于某些用例,最好不要改变数组：

Rx.observable
  .from(["a",value) => [...acc,value],[])
  .subscribe(value => console.log(JSON.Stringify(value)));

<script src="https://unpkg.com/rxjs@5/bundles/Rx.min.js"></script>

请注意,扫描会为其接收的每个值发出一个数组.如果您只想在observable完成时发出一个数组,则可以使用toArray运算符：

Rx.observable
  .from(["a","c"])
  .concatMap(value => Rx.observable.of(value))
  .toArray()
  .subscribe(value => console.log(JSON.Stringify(value)));

<script src="https://unpkg.com/rxjs@5/bundles/Rx.min.js"></script>