src/pipes/reducer/averageDeep.js

import { map } from "rxjs/operators";
import { average } from "../../utils/stats";

/**
 * @method averageDeep
 * Averages list of values including deep lists, to a single value
 *
 * @returns {Observable} average
 */
export const averageDeep = () =>
  map(
    channels =>
      channels.reduce(
        (acc, value) => acc + (Array.isArray(value) ? average(value) : value),
        0
      ) / channels.length
  );