Redux saga eventChannel websocket

如何解决Redux saga eventChannel websocket

我通过 websocket 获取数据，我的浏览器在一段时间内死机。我做错了什么？

这是完整的代码 https://codesandbox.io/s/saga-channel-websocket-tmkzk

这是传奇代码的一部分。也许我应该从这部分删除一些东西？我不知道我要添加或删除什么。谁有 saga 编写 eventChannel 的经验，如果你推荐我，我很感激？

function initWebsocket() {
  console.log('initWebsocket');
  return eventChannel(emitter => {
    //Subscription Data
    console.log('initWebsocket channel');
    const subscribe = {
      type: "subscribe",channels: [
        {
          name: "ticker",product_ids: ["BTC-USD"],},],};

    //Subscribe to websocket
    let ws = new WebSocket("wss://ws-Feed.pro.coinbase.com");
    console.log('WebSocket ws',ws);

    ws.onopen = () => {
      console.log("opening Websocket");
      ws.send(JSON.stringify(subscribe));
    };

    ws.onerror = error => {
      console.log("ERROR: ",error);
      // console.dir(error);
    };

    ws.onmessage = e => {
      let value = null;
      try {
        value = JSON.parse(e.data);
        console.log('value',value,typeof value);
      } catch (e) {
        console.error(`Error Parsing Data: ${e.data}`);
      }
      if (value && value.type === "ticker") {
        emitter({
          type: "POST_LIVE_PRICE_DATA",data: value,});
      }
    };

    return () => {
      ws.close();
    };
  });
}

function* wsSaga() {
  const channel = yield call(initWebsocket);
  console.log('channel',channel);
 // is this correct part?
  try {
    while (true) {
      const action = yield take(channel);
      // console.log('action',action);
      yield put(action);
    }
  }
  catch (err) {
    debugger
  }
  finally {
    if (yield cancelled()) {
      channel.close()
      console.log('countdown cancelled')
    }
  }
}