RXJS管道在发出之前对bufferTime窗口的值求和？

如何解决RXJS管道在发出之前对bufferTime窗口的值求和？

我正在尝试分析一系列脑电图样本。我正在使用Muse 2头带，该头带具有用于连接和获取读数的javascript库。我使用基于React的Rxjs接口。我对Observable和Rxjs的整个概念是陌生的。下面列出了我正在使用的库。

• Muse-JS
• EEG-Pipes
• Charts JS

此刻，我正在使用this项目中的代码来生成模拟数据，以便我可以测试代码。

我使用下面的代码通过从模拟数据流中获取的样本构建了一个嵌套数组：

export function record(){

console.log('Start recording');
let recordBandData = [];

// Create timer
const timer$ = timer(10000);

window.fftData$ = zipSamples(window.source.eegReadings$)
    .pipe(
        bandpassFilter({
            cutoffFrequencies: [0.5,45],nbChannels: window.nchans,samplingRate: 256
        }),epoch({
            duration: 1024,interval: 256,fft({
            bins: 1024
        }),powerByBand({
            delta: [0.5,4],theta: [4,8],alpha: [8,12],beta: [12,30],gamma: [30,low: [4,13],high: [25,42]
        })
    )
catchError(err => {
    console.log(err);
})

window.fftData$
    .pipe(
        takeUntil(timer$),bufferTime(1000),catchError(err => {
            console.log(err)
            }
        )
    )
    .subscribe({
        next(x){
            recordBandData.push({
                samples: x,timestamp: Date.now()
            })
        },complete(){
            console.log('Completed')
            console.log(recordBandData)
        }
    })}

对于10秒钟的录制，我得到下面的数组：

现在，我要做的是创建一个将所有这些值求和的函数，并仅返回一个单个对象，每个窗口的平均值为1s。因此，除了拥有巨大的嵌套数组之外，我将只有10个数组（记录10秒的1秒窗口），该数组保存1秒窗口读数的平均值。

以后我想在1分钟的窗口中进行30分钟的录制...