fix: 取消递归调用，改为循环模式

jensen.d.ts

@@ -307,7 +307,7 @@ declare class Jensen {
   stopRealtime: (seconds?: number) => Promise<ReturnStruct['common']>;
   
   // 获取实时音频流数据
-  getRealtime: (frames: number, mute: boolean, seconds?: number) => Promise<{ data: Uint8Array | null; rest: number, muted: boolean }>;
+  getRealtime: (frames: number, seconds?: number) => Promise<{ data: Uint8Array | null; rest: number, muted: boolean }>;
   
   // 录音文件随机读取，从指定位置起读取指定数量个字节
   readFile: (fname: string, offset: number, length: number) => Promise<Uint8Array>;

src/index.tsx

@@ -538,7 +538,7 @@ export function Home() {
   const scheduleLiveTick = async () => {
     let jensen = getJensen();
     if (jensen == null) return;
-    let live = await jensen.getRealtime(1, muteRef.current, 1);
+    let live = await jensen.getRealtime(1, 1);
     // 若无数据直接调度下一次
     if (live?.data == null) return;
     setLiveStates('live: ' + live.data.length + ' rest: ' + live.rest + ' muted: ' + live.muted + ' == ' + muteRef.current);

src/utils/jensen.js

@@ -80,6 +80,10 @@ const COMMAND_NAMES = {
 
 let Logger = null;
 
+const sleep = (ms) => {
+  return new Promise(resolve => setTimeout(resolve, ms));
+}
+
 function Jensen(log, conn) {
   Logger = log || internalLogger;
   let device = conn;
@@ -95,6 +99,7 @@ function Jensen(log, conn) {
   let totalBytes = 0;
   let handlers = {};
   let pid = 0;
+  let recvable = false;
 
   let self = this;
   this.data = {};
@@ -110,6 +115,7 @@ function Jensen(log, conn) {
   this.onerror = null;
 
   const RECV_BUFF_SIZE = 512000;
+  // let cache = new ArrayBuffer(RECV_BUFF_SIZE * 2);
 
   const _check_conn_status = () => {
     if (device?.opened === false) {
@@ -172,6 +178,10 @@ function Jensen(log, conn) {
     } catch (err) {
       Logger.error('jensen', 'setup', err);
     }
+
+    setTimeout(async () => {
+      receive();
+    }, 0);
   };
 
   this.initialize = async function() {
@@ -335,7 +345,7 @@ function Jensen(log, conn) {
         }
         */
     totalBytes = 0;
-    if (recv == false) tryReceive();
+    if (recv == false) startReceive();
     else recv = true;
   };
 
@@ -403,19 +413,13 @@ function Jensen(log, conn) {
     }
   };
 
-  const tryReceive = function () {
-    if (device)
-      // console.log('trace', device);
-      device.transferIn(2, RECV_BUFF_SIZE).then((r) => {
-        Logger.save?.('jensen', 'tryReceive', r?.data);
-        console.log(pid + '-Receive', new Date().toLocaleString(), r?.data);
-        receive(r);
-      }).catch((e) => {
-        console.log('tryReceive error', e)
-        self.onerror?.(e);
-      });
-      
-  };
+  const startReceive = function () {
+    recvable = true;
+  }
+
+  const stopReceive = function () {
+    recvable = false;
+  }
 
   const read_int = function (a, b, c, d) {
     if (arguments.length === 2) {
@@ -425,24 +429,31 @@ function Jensen(log, conn) {
     }
   };
 
-  const receive = function (result) {
-    if(result instanceof Error) {
-      console.log('receive error', result);
-      return 
+  const receive = async function () {
+    while (true) {
+      let r = await tryReceive();
+      if (r == null || r instanceof Error) {
+        console.log('receive error', r);
+        await sleep(30);
+        continue;
+      }
+      totalBytes += r.data.byteLength;
+      blocks.push(r.data);
+      if (self.decodeTimeout) clearTimeout(self.decodeTimeout);
+      self.decodeTimeout = setTimeout(function () { tryDecode(); }, self.timewait);
+      self.onreceive?.(totalBytes);
     }
-    totalBytes += result.data.byteLength;
-    // 做一个回调，怎么样找到它呢？
-    blocks.push(result.data);
-    tryReceive();
-    if (self.decodeTimeout) clearTimeout(self.decodeTimeout);
-    self.decodeTimeout = setTimeout(function () {
-      tryDecode();
-    }, self.timewait);
-    if (self.onreceive) {
-      try {
-        self.onreceive(totalBytes);
-      } catch (e) {}
+  };
+
+  const tryReceive = async function () {
+    let r = null;
+    if (device && recvable)
+    {
+      r = await device.transferIn(2, RECV_BUFF_SIZE);
+      Logger.save?.('jensen', 'tryReceive', r?.data);
+      console.log(pid + '-Receive', new Date().toLocaleString(), r?.data);
     }
+    return r;
   };
 
   const tryDecode = function () {