如何随着时间的推移累积每个值的出现次数？

Question

要求

给定一个字母流：'a'、'a'、'b'、'b'、'b'、'c'

发出以下输出，这是到目前为止遇到的每个字母出现次数的总和：

[{ letter: 'a', count : 1 }]
[{ letter: 'a', count : 2 }]
[{ letter: 'a', count : 2 }, { letter: 'b', count : 1 }]
[{ letter: 'a', count : 2 }, { letter: 'b', count : 2 }]
[{ letter: 'a', count : 2 }, { letter: 'b', count : 3 }]
[{ letter: 'a', count : 2 }, { letter: 'b', count : 3 }, { letter: 'c', count : 1 }]

潜在解决方案 #1

类似于https://stackoverflow.com/a/32878533/1188074 - 我最初尝试过这样的事情，但认为它不是很'rxjs like'。根据解决方案 #2 再次查看它，它要简单得多，而且很可能是要走的路。

潜在解决方案 #2

部分尝试：https://stackblitz.com/edit/so-accumulated-letters 基于https://stackoverflow.com/a/53021875/1188074
它在打印单个字母计数时起作用，即：

{ letter: 'a', count : 1 }
{ letter: 'a', count : 2 }
{ letter: 'b', count : 1 }
{ letter: 'b', count : 2 }
{ letter: 'b', count : 3 }
{ letter: 'c', count : 1 }

但是它不跟踪其他以前的字母。我尝试过使用另一个scan、combineAll 等

1. 我应该使用解决方案 #1 还是 #2 中的方法？
2. 如果是 #2，我怎样才能让它累积其他字母数？

谢谢

Answer 1

试试这个：

    const source = ['a', 'b', 'a', 'c', 'd', 'b', 'a'];
    interval(1000)
      .pipe(
        take(7),
        map(i => source[i]),
        groupBy(e => e),
        mergeMap(group => {
          let i = 1;
          return group.pipe(map(e => ({letter: group.key, count: i++})))
        }),
        scan((acc, current) => {
          const index = acc.findIndex(item => item.letter === current.letter);
          if(index > -1) {
            acc[index] = current;
          } else {
            acc.push(current);
          }
          return acc;
        }, [])
      )
      .subscribe(x => console.log(...x))

Demo-1

---

更新

另一个简单的解决方案是只使用map 和scan：

source
  .pipe(
    map(e => ({letter: e, count: 1})),
    scan((acc, current) => {
      const index = acc.findIndex(item => item.letter === current.letter);
      if(index > -1) {
        acc[index].count++;
      } else {
        acc.push(current);
      }
      return acc;
    }, [])
  )
  .subscribe(x => console.log(x))

Demo-2