Вызов преобразований после вызова `group` в highlandjs

Question

Цель - сгруппировать элементы в потоке в несколько групп. Запустите преобразования для этих групп по отдельности, а затем заново объедините все группы в один поток.

Единственный вызов, который я могу использовать после group, кажется each, и он не передает отдельные группы моему обратному вызову, он передает весь словарь сгруппированных объектов. Звонок map ничего не передаст моему обратному вызову. Пример:

const groups = stream.group(func);
groups.map(item => console.log(item)); // prints nothing
groups.each(item => console.log(item)); // instead of item being one of the groups created, it's a dictionary with all the groups included. 

Как я могу это сделать?

Answer 1

вы ищете для этого?:

groups.on('error', handleError)
        .pipe(transformObject(async item => {
            some code...

Если нет, попробуйте привести пример того, что вы хотите сделать со своими данными.