反应 redux saga websocket binance 流答案

【问题标题】：react redux saga websocket binance stream反应 redux saga websocket binance 流
【发布时间】：2020-06-06 23:44:00
【问题描述】：

无法从 saga 派发动作，请查看 foo saga，这是完整代码和最近推送 github link 我可以知道我哪里出错了吗？没有 saga 它工作正常，但我想用 saga 实现贸易应用程序。

import { takeEvery, put, call, take } from 'redux-saga/effects'
import {
    updateMarketPairs
} from '../actions/updateMarketPairs'

export default function* marketPairsSagas() {
    yield takeEvery("UPDATE_MARKET_PAIRS", connectSocketStreams)

}

function doAction (data){
    let ticker = {}
    data.forEach(item => {
        let symbol = item.symbol || item.s;
        ticker[symbol] = {
            symbol: symbol,
            lastPrice: item.lastPrice || item.c,
            priceChange: item.priceChange || item.p,
            priceChangePercent: item.priceChangePercent || item.P,
            highPrice: item.highPrice || item.h,
            lowPrice: item.lowPrice || item.l,
            quoteVolume: item.quoteVolume || item.q,
        }
    }) 
    return ticker;

}

function* foo (tickerdata) {
    console.log("yielding");  // appears in console
    console.log('after yielding tickerdata',tickerdata);
    yield put(updateMarketPairs(tickerdata));  // action *is not* dispatched
    console.log("yielded"); //appears in console
}

 function connectSocketStreams(action) {
    const payload = action.payload
    const allStreams = payload.streams && payload.streams.join('/');
    let connection = btoa(allStreams);
    connection = new WebSocket(`wss://stream.binance.com:9443/stream?streams=${allStreams}`);
    connection.onmessage = evt => {
        // yield put({ type: 'ACTION_TYPE', payload: JSON.parse(evt.data)})
        let tickerdata = doAction(JSON.parse(evt.data).data);
        const iter = foo(tickerdata);
        iter.next();
        // yield put(updateMarketPairs(tickerdata));
        console.log('tickerdata saga---->',tickerdata);
    }
    connection.onerror = evt => {
        console.error(evt);
    }
    // yield put(updateMarketPairs(tickerdata));
}

【问题讨论】：

标签： reactjs react-redux redux-saga saga

【解决方案1】：

那是因为foo 是一个生成器，你不能像普通函数一样调用它。你需要使用 redux-saga call 效果。

但还有另一个问题：call 效果在 onmessage 处理程序中不起作用。对于这种情况，有一个 eventChannel 帮助器，可以让 saga 与外部事件源进行通信。

【讨论】：