Как правильно объединять потоки в rxjs?

Question

[Николай Купстас]

Привет! У меня из бд приходит массив, содержащий в себе данные для построения дерева. Но у меня возникла проблема в построение сего в rxjs

Сейчас мой код выглядит так:

services
            .tree
            .collection
            .find()
            .$
            .pipe(
                switchMap(from),
                groupBy((value) => value.get('parent_id')),
                mergeScan((memo, group$) => {
                    const key = group$.key;

                    return group$.pipe(
                        map((value) => {
                            if(!(key in memo)) {
                                memo[key] = [];
                            }
                            memo[key].push(value);

                            return memo;
                        })
                    )
                }, {}),
            )
            .subscribe((data) => console.log('data', data));

И вроде бы в итоге я получаю то, что надо, только вместо одной записи в консоли я получаю очень даже много. Подскажите, как в таком случае правильно всё объединить, чтобы в итоге у меня был один пайплайн?

Answer 1

[Антон Швец]

У вас обычный массив на входе, постройте из него дерево любым простым алгоритмом, зачем тут потоки городить?

Comments

[Николай Купстас]

Потому что мне из бд приходит поток

[Антон Швец]

Николай Купстас, т.е. если вы хотите одну запись в консоль, значит поток должен завершаться.
Если это так, надо просто взять последнее значение, через last например. Или toArray, чтобы собрать их.

Меня смущает ваш from в самом начале. Такое чувство что вы просто массив получаете, а потом распускаете его на потоки.
В этом случае намного проще сделать какой-нибудь плоский map(makeTree), а не выстраивать хитрую конструкцию с groupBy.
Что-то типа такого

spoiler

const { of } = require('rxjs');
const { map } = require('rxjs/operators');
function genFactory() {
  let i = 1;
  return () => ({
    parentId: i < 2 ? null : Math.floor(Math.random() * i) + 1,
    id: i++,
  });
}

function makeTree(arr) {
  let root;
  const treeMap = arr.reduce((acc, el) => {
    el.parentId === null && (root = el);
    el.children = [];
    acc[el.id] = el;
    return acc;
  }, {})
  arr.forEach(el => el.parentId && treeMap[el.parentId].children.push(el));
  return root;
}

of(Array.from(Array(30), genFactory())).pipe(
  map(makeTree),
)
  .subscribe(r => console.log(JSON.stringify(r, null, '  ')));

[Николай Купстас]

Антон Швец, я в итоге так и сделал