我有一个在听动作的传奇故事。当这个动作被分派时,它执行一个阻塞调用。
问题是,许多动作(相同的动作)在同一时间内被调度,而我的传奇故事不能接受所有的动作。但我需要同步处理每个操作。
我知道这是redux-saga文档中的一个已知问题:My Saga is missing dispatched actions
但事实是我不能使用fork,因为我真的需要在处理新的调用之前结束上一个调用。
下面是我的代码:
export function* readProducts() {
while (true) {
const {
payload: { tags },
} = yield take(RFID__ADD_PRODUCT);
// sequential add of each item
for (const tag of tags) {
yield call(addProductViaRfid, tag);
}
}
}
有谁有解决方案吗?
发布于 2019-11-21 19:14:30
您可以创建缓冲操作通道并从中执行操作。
export function* readProducts() {
const addProductRequests = yield actionChannel(RFID__ADD_PRODUCT);
while (true) {
const {
payload: { tags },
} = yield take(addProductRequests);
// sequential add of each item
for (const tag of tags) {
yield call(addProductViaRfid, tag);
}
}
}
https://stackoverflow.com/questions/58973428
复制相似问题