问题描述
我通过 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')
}
}
}
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)