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

编程问答 2022-10-25

问题描述

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

此刻，我正在使用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秒钟的录制，我得到下面的数组：

enter image description here

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

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

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

arraysarraysarraysneurosciencereactjsreactjsreactjsreactjsreal-time-datarxjsrxjs