saga

    0热度

    1回答

    花了几个小时试图弄清楚如何在地图内并行运行传奇。 试过了我发现的东西:yield result.map(item => call(api.endpoint, item)) 但似乎没有发生。 下面是我在做什么:在for循环工作完成后 export function* syncCanvasesByFolder(<someParams>) { yield call(api.syncCanvas

    0热度

    1回答

    我有配置了UseInMemoryOutbox(一MT状态机),这样是事件处理的一部分将只发布的任何消息的订单后在管道中的最后一步是成功的完成,在我的情况是,状态持久性Couchbase。 Initially(When(A). ThenAsync(async context => { context.Instance.IsAutoApprov

    2热度

    1回答

    如果消息由于异常而被“重试”,是否将其物理返回到队列?到一开始?到最后?它是否在队列中存在的消息之后被重新处理?它是否保存在应用程序内存中? 我还没有发现masstransit重试机制流在文档中的任何说明。 请参阅任何解释它的文档,谢谢。

    1热度

    1回答

    如何测试选择效果?我的传奇取决于选择的结果,但每次我只是从传奇中获得undefined。 这里是我的尝试: 在我的传奇: function* loadData() { const foo = yield select((state) => { return state.foo.value; }); console.log('foo is :', foo)

    1热度

    1回答

    我是新来的传奇。 这里一个简单的场景: 用户点击“创建订单”:一个订单被创建(持有其状态= NEW先) 一旦用户完成填写订单,点击保存 - - >状态现在已提交 当另一个检查订单并对其进行验证时,则必须执行一个过程。只有在调用某些其他服务并给出它们的GO时,订单才会有效。 整个工作流程是: NEW - >SUBMITTED。 从SUBMITTED用户可以取消提交和订单切换回NEW。 验证可以将订单

    0热度

    1回答

    在我当前的项目中,我正在处理firebase websocket订阅。不同的组件可以订阅不同的数据,例如,在每个ListItem组件的订单列表中,通过分派componentDidMount中的SUBSCRIBE动作和通过分派componentWillUnmount中的UNSUBSCRIBE动作取消订阅,订阅了该特定项目的websocket“事件”。 我的传奇故事是这样的: const subscr

    0热度

    1回答

    我是REDX-SAGO的小菜,如果我错过了一些明显的东西,请耐心等待。 我有一个场景,我使用的是REDX-SAGA从OIDC提供程序中获取access_token并将其存储在浏览器的localStorage中。 我也使用Sagas从API端点获取一些数据。 但是我一直在使用这种方法遇到问题,因为调用外部API的Saga在Auth Saga可以使用access_token解析之前被调用。 我的验证城

    1热度

    1回答

    当我发布这样的事件时,有没有什么办法可以在saga中访问标题? await busControl.Publish<IOrderCreated>(new { OrderId = dto.Id }, context => { context.Headers.Set(LogConstansts.Common.OperationId,Guid

    2热度

    1回答

    我使用卡夫卡进行事件采购,我有兴趣使用卡夫卡实施传奇。我做了一些研究,但没有找到关于这个话题的任何内容。有很多关于萨加斯的信息,但我觉得使用卡夫卡的实现可能涉及几个错综复杂的问题。有关如何做到这一点的最佳做法?指挥官模式提到here似乎接近我试图建立的架构,但在演示文稿的任何地方都没有提到传奇故事。

    1热度

    1回答

    我想通过END效果(详细信息https://github.com/redux-saga/redux-saga/issues/255,解释为什么这是如此棘手)我的应用程序到服务器端渲染。 我的数据依赖于2个异步请求:getJwtToken -> (with token data) FetchItem -> now render。 这可能吗? 我花了很多时间看频道(这里是https://redux-s