无法在使用Redux Observable执行mergeMap之后传播值
在使用Redux Observable执行mergeMap之后，无法传播值的问题可能是由于以下原因导致的：
- 错误的操作符使用：在使用mergeMap时，需要确保正确地使用操作符来处理传播值。可能需要使用其他操作符，如switchMap、concatMap或exhaustMap，根据具体的需求来选择合适的操作符。
- 错误的Observable返回：在mergeMap中，需要确保返回一个Observable对象，以便继续传播值。如果返回的是其他类型的值，如普通的数据对象或Promise对象，将无法继续传播值。
- 异步操作未正确处理：如果在mergeMap中执行的是异步操作，需要确保正确地处理异步操作的完成和错误情况。可以使用catchError操作符来捕获错误并进行处理，以避免中断传播值。
- Redux状态管理问题：如果在mergeMap之后无法传播值，可能是由于Redux状态管理的问题导致的。需要确保正确地更新和访问Redux中的状态，以便正确地传播值。
针对这个问题，可以尝试以下解决方案：
- 确保正确使用合适的操作符来处理传播值，可以根据具体需求选择switchMap、concatMap或exhaustMap等操作符。
- 确保在mergeMap中返回一个Observable对象，以便继续传播值。
- 如果在mergeMap中执行异步操作，确保正确地处理异步操作的完成和错误情况，可以使用catchError操作符来捕获错误并进行处理。
- 检查Redux状态管理的相关代码，确保正确地更新和访问Redux中的状态。
以下是一些相关的腾讯云产品和产品介绍链接，可以帮助解决该问题：
- 腾讯云云函数（Serverless）：https://cloud.tencent.com/product/scf
- 云函数是一种无服务器计算服务，可以帮助简化后端开发和部署，提供弹性扩展和高可靠性。
- 腾讯云消息队列（CMQ）：https://cloud.tencent.com/product/cmq
- 消息队列是一种高可靠、高可用的消息传递服务，可以帮助解耦和异步处理。
- 腾讯云数据库（TencentDB）：https://cloud.tencent.com/product/cdb
- 腾讯云数据库提供多种数据库服务，包括关系型数据库（MySQL、SQL Server等）和NoSQL数据库（MongoDB、Redis等），可以满足不同的存储需求。
请注意，以上链接仅供参考，具体的产品选择应根据实际需求和情况进行评估和决策。
相关·内容
我对reactjs很陌生，并试图将redux与我现有的项目集成起来。
这是我的index.js文件
import 'rxjs'
import { createStore, combineReducers, applyMiddleware } from 'redux'
import { reducer as formReducer } from 'redux-form'
import thunk from 'redux-thunk'
import promise from 'redux-promise-middleware&
浏览 1提问于2018-10-01得票数 5
回答已采纳
1回答
可观测史诗的测试误差处理
、、、、
这里我使用redux-observable，测试错误处理时遇到了一些问题。
请参阅下列注销用户史诗：
const logoutUserEpic = (action$) => action$
.ofType(LOGOUT_USER)
.mergeMap(() =>
Observable.from(
graphQl(AuthLogout)
.catch((error) => failure(error))
)
.mergeMap(() => Observa
浏览 2提问于2017-04-29得票数 2
回答已采纳
我对反应性编程非常陌生，我想将下面的代码从redux-saga转换为redux-observable。
这样做的目的是等待一些API调用，等待5s并调度另一个操作。
function* mySaga(action) {
const response = yield call(someApiCall);
yield call(delay, 5000);
yield put({ type: 'ACTION' });
}
下面是我在redux--可观察到的--中如何做的：
action$
.ofType('SOME_ACTION')
.mergeM
浏览 3提问于2017-09-15得票数 2
回答已采纳
3回答
引言
我试图使用共享服务中的可观察性在Angular2+中创建一个路由保护，该服务保存当前用户角色的字符串值。
问题显然是把我的注意力从承诺转移到了可观察范围内。
到目前为止，我所做的是基于启发式和尝试&错误方法，但我通过杀死浏览器来解决问题，这是由于danday74解决了问题。
。
尝试(由于@danday74 74而得到改进)
在的帮助下，我将我想要做的事情翻译成这样的链：
canActivate(route: ActivatedRouteSnapshot): Observable<boolean> | boolean {
return this
浏览 0提问于2018-10-16得票数 7
回答已采纳
我刚接触过Redux-可观察的。因此，我在我的项目中应用了redux可观察性，并且我希望通过redux可观察的方式分派操作，因此我使用了"of“(就像之前RXJS版本中的Observable.of() )。但是我收到的回复是“操作必须是普通对象。使用自定义中间件进行异步操作”。我设置的史诗中间件或代码有问题吗？
store.js
import { createStore, applyMiddleware, compose } from 'redux';
import { createEpicMiddleware } from 'redux-observable&
浏览 2提问于2018-08-28得票数 2
回答已采纳
我试着理解，mergeMap在这个例子中是如何工作的，但仍然不理解。你能帮帮我吗?
import { interval } from 'rxjs';
import { mergeMap, take } from 'rxjs/operators';
// emit value every 1s
const source$ = interval(1000);
source$
.pipe(
mergeMap(
// project
val => interval(5000).pipe(take(2)),
//
浏览 1提问于2021-04-23得票数 0
回答已采纳
2回答
我有一个方法，它将一个可观测的参数作为参数，并返回另一个可观测的方法(如果您想要在Redux可观测的基础上加快速度，那么它就具有这种类型的签名function (action$: Observable<Action>): Observable<Action>; )
在该方法中，当接收到'POST_AND_GET_REQUEST'操作时，我需要可观察的执行以下操作：
使用操作的有效负载部分为数组中的每个对象同步执行POST请求，这些同步调用完成后，在GET请求返回响应时执行GET请求，然后返回'POST_AND_GET_SUCCESS'操作
浏览 0提问于2020-01-10得票数 1
我正在尝试使用payload.type = 'observable‘分派'SET_MIDDLEWARE_TYPE’操作，等待5秒，然后进行API调用。当前未调度SET_MIDDLEWARE_TYPE操作。如果我删除了延迟和mergeMap，它就会分派该操作。
预期: FETCH_USER_WITH_OBSERVABLE_REQUEST --> SET_MIDDLEWARE_TYPE (等待5秒) --> FETCH_USER_WITH_OBSERVABLE_SUCCESS
实际: FETCH_USER_WITH_OBSERVABLE_REQUEST --> (
浏览 10提问于2017-01-21得票数 1
回答已采纳
我正在寻找在单个redux-observable中间件史诗中分派多个redux操作的方法。
让我们假设我关注了Epic。每次发生SEARCH事件时，Epic都会从后台加载数据并调度RESULTS_LOADED操作。
searchEpic = (action$) =>
action$
.ofType('SEARCH')
.mergeMap(
Observable
.fromPromise(searchPromise)
.map((data) => {
return {
浏览 0提问于2016-11-30得票数 45
回答已采纳
1回答
我正在与做斗争，试图弄清楚如何用这个流程创建一部史诗：
侦听GET_ITEMS_REQUEST操作
发送HTTP请求以获取一些项
获取这些项的ID并分派一个GET_ITEM_DETAILS_REQUEST操作，该操作将发送另一个HTTP请求，以获取这些项的更多详细信息
使用来自第二个请求的详细信息来装饰来自第一个请求的项目，并发送一个最终的GET_ITEMS_SUCCESS操作，它将更新redux状态。
从第三步到第四步是我被困的地方。我知道如何使用项目I分派GET_ITEM_DETAILS_REQUEST，但不知道如何侦听/订阅GET_ITEM_DETAILS_REQ
浏览 3提问于2017-02-16得票数 2
回答已采纳
你能告诉我为什么会出现这个错误吗？ ? import { FETCHING_DATA } from '../constants'
import { getDataSuccess, getDataFailure } from './actions'
import getPeople from '../api'
import { from, Observable, of} from 'rxjs';
// import 'rxjs'
// import { Observable } from 'rxj
浏览 17提问于2020-04-02得票数 0
回答已采纳
我正在努力学习redux--可观察性，但我似乎在获取我的应用程序返回数据时遇到了问题。我不断地得到下面的错误，我不知道我在哪里出错，或者这个错误实际上意味着什么。
错误: axios__WEBPACK_IMPORTED_MODULE_3___default.a.get(...).map不是一个函数TypeError：
操作：
import { FETCH_DATA, FETCH_DATA_FAIL } from './constants';
export const fetchData = exampleData => ({
type: FETCH_DATA,
payl
浏览 0提问于2019-01-09得票数 2
回答已采纳
我有这样的东西：
// getNums returns of Obsevable<number[]>
nums : Observable<number[]> = getNums();
// requestNum is a server call that takes a number and returns Observable<number>
serverNums : Observable<Observable<number>[]> = x.pipe(
map(num_array => num_array.map(n
浏览 0提问于2019-01-19得票数 4
在React/Redux应用程序中，我使用可观察的Redux，我想要一个epic来输出两个不同的操作。
首先，我尝试了这个：
const epic1 = action$ =>
action$
.ofType("A")
.mapTo({ type: "B" })
.merge(Observable.of({ type: "C" }));
由于它不起作用，我不得不切换到：
const epic2 = action$ =>
action$
.ofType("D")
.merge
浏览 0提问于2018-05-07得票数 2
回答已采纳
我使用的是redux可观察的，这就是我想要做的。
当“APPLY_SHOPPING_LIST”的操作类型出现时，分派'APPLYING_SHOPPING_LIST‘和5秒后发出’APPLIED_LIST‘。这是我到目前为止想出的代码
const applyingShoppingListSource = action$.ofType('APPLY_SHOPPING_LISTS').mapTo({ type：'APPLYING_SHOPPING_LISTS‘}；const applyingShoppingListSourceOther = action$.ofT
浏览 2提问于2017-05-02得票数 0
回答已采纳
1回答
我正在使用redux-observable和一个附带项目进行测试，并且反复遇到这个问题：Uncaught TypeError: combineEpics: one of the provided Epics "handleSearchEpic" does not return a stream. Double check you're not missing a return statement!
我已经在网上引用了redux、可观察的文档和其他几个例子，但是我无法确定我可能丢失了什么。下面是我的行动和史诗的问题。
export const searchContent
浏览 2提问于2017-05-13得票数 2
回答已采纳
1回答
当一个mergeMap失败时，我似乎想不出如何继续它的角度。
我把两个mergeMap调用串在一起，调用一个可观察到的pipe内部。两个调用都完成了所有调用，但是第二个合并映射调用中的一个返回一个错误，因此第二个合并调用都不会被映射。
Observable.pipe(
mergeMap(
result => {
return stuff
});
}
), mergeMap(result => {
return stuff //one of the calls here will error, but the re
浏览 7提问于2022-01-22得票数 0
回答已采纳
1回答
我在角2中有这个函数，我没有写它，但它目前工作正常：
myFunction(): Observable<Song> {
return this.user.getSong$()
.mergeMap((track: Track) => {
if (track.isSingle()) {
return this.getSingle(track.getId());
} else {
throw 'error';
浏览 1提问于2019-03-01得票数 0
回答已采纳
我想用redux observable来管理我的抓取，但是我找不到任何例子。有人能回答这个问题吗？
通过阿波罗vanillaJS，这是获取我的查询结果的方法：
const opts = {uri: 'http://localhost:8080/graphql'};
const networkInterface = createNetworkInterface(opts);
const client = new ApolloClient({
networkInterface});
let query = gql`query {
viewe
浏览 0提问于2017-06-28得票数 1
我有一个现有的项目，它使用状态、Redux可观察中间件和RXJS5.x的ImmutableJS。我注意到使用RXJS 6.x的Redux Observable的最新版本具有与以前不同的依赖注入模式。具体地说，存储注入已被"state$“流替换。我的问题是，我可以在ImmutableJS上使用RXJS6.x吗？我会把“状态$”当作一个普通的不可变对象，并使用"state$.get('username')“这样的东西吗？
浏览 8提问于2018-07-26得票数 0
我有一个redux observable epic，它将AJAX响应映射到单个操作("createSuccess")： export const create = (action$) => {
return action$.pipe(
ofType(CREATE_REQUEST),
mergeMap(action => {
return ajax({...}
).pipe(
map((response) => createSucce
浏览 14提问于2019-06-14得票数 1
回答已采纳
只有当我直接订阅它时，Observable.bindCallback才会返回值--换句话说，它工作得很好：
return this.store.select(store => store.appDb.appBaseUrl)
.take(1)
.mergeMap(baseUrl => {
const url = `${baseUrl}?command=GetCustomers&resellerUserName=aaa&resellerPassword=bbbb`;
浏览 4提问于2016-12-28得票数 1
回答已采纳
我有一个操作，然后触发ajax请求。
如果行动因某种原因失败，我什么也不想做。不是创建一个只返回前一个状态的空白操作，而是可以执行无操作函数吗？
export default function fetchMeetups(action$) {
return action$.ofType(statusActions.START_APP)
.mergeMap(action =>
ajax.getJSON(`${config.API_BASE_URL}/api/v1/meetups`)
.map(meetups => calendarActions.me
浏览 1提问于2017-04-18得票数 7
回答已采纳
1回答
我有这样一篇史诗，POST是一个json主体，但它实际上从未发送实际的网络请求。它使用 (我想？请查看我的进口以确认)。我可以验证一下，网络请求永远不会从我的应用程序中得到，更不用说我的后端了：
import { Observable } from 'rxjs'
import 'redux-observable'
import {
UPLOAD_IMAGE,
UPLOAD_IMAGE_FULFILLED,
UPLOAD_IMAGE_REJECTED,
UPLOAD_PRODUCT,
uploadImageFulfilled,
upload
浏览 3提问于2017-05-22得票数 1
回答已采纳
1回答
是否有更实用的方法将这些观测数据与RX/JS嵌套在一起。下面是一个片段，我首先存储一个图像，然后返回下载URL并将其放在实时数据库中。
return new Observable(observer => {
firebase.storage().ref().child('users/' + this.userService.getUserID() + '/messages/').put(image).then((data) => {
updates['photoURL'] = data.downl
浏览 7提问于2017-09-05得票数 0
回答已采纳
我的Angular 5应用程序基于，这是一个类似于Redux但基于RxJS的状态管理库。
我经常需要根据当前操作的有效负载从存储中获取最新的值。
在RxJS术语中，这意味着我有不断产生项目的主流，对于每个新项目，我需要基于项目的值创建一个副流，从该流中获取最新的值，并将其与主流组合。
目前，我这样做：
@Effect()
public moveCursor$: Observable<Action> = this.actions$.pipe(
ofType<TableAction.MoveCursor>(TableActionType.MOVE_CURSOR),
浏览 0提问于2018-03-12得票数 6
我对rxjs和redux-observable非常陌生。我尝试在一个epic中发出两个ajax请求，如下所示： import { mergeMap, filter, map, catchError } from 'rxjs/operators';
import { of } from 'rxjs';
import { ofType } from 'redux-observable';
import { push } from 'connected-react-router';
export const doSomethin
浏览 14提问于2020-03-24得票数 1
我一直在努力解决这个问题，感觉我有一个根本性的误解。我使用的是React中的redux-observable库，它将redux与RxJS粘合在一起来处理异步。我的问题是我必须处理一个大的上传，我想在文件加载时显示进度。
函数uploadFileEpic需要返回一个Observable<Action>才能使用redux-observable。uploadObservable表示我想要完成的工作流程。如果我只是返回uploadObservable，那么上载就可以工作了，但是在ajax调用中，我没有从progressSubscriber获得任何handleUploadFileProgre
浏览 1提问于2018-12-15得票数 4
我不是类型记录，Javascript或前端开发人员。我继承了角13计划。有一个函数返回Observable<Dto[]>。我在代码中看到了这样的东西：
this.service.getStuff(arg).pipe(
mergeMap(x => x),
concatMap(y => { return this.service.getOtherStuff(x.subObj.id).pipe(
map(v => ({ obj1: y, obj2: v})));
})
).subscribe(
// ... do somethin
浏览 6提问于2022-10-11得票数 1
回答已采纳
我读过这篇，但它并不能帮助我找到答案。
我在我的react-redux应用程序中使用redux-observable，我有一个epic将触发API调用，代码如下：
const streamEpicGet = (action$: Observable<Action>, state$) => action$
.pipe(
ofType(streamActions.STREAM_ITEM_GET),
withLatestFrom(state$),
mergeMap(([action, state]) => {
return observ
浏览 1提问于2019-06-25得票数 0
1回答
我有以下声明，它与rxjs5.5和redux observable 0.x一起工作得很好。现在，我使用redux-observable v1和rxjs v6。我不知道如何将race转换为下面的代码(因为它的用法已被弃用)。
(action$, state$) =>
action$.pipe(
ofType(REQUEST),
switchMap(action => {
return race(
action$.pipe(
ofType(REQUEST_CANCEL),
浏览 42提问于2018-08-04得票数 0
回答已采纳
1回答
我尝试在rxjs中以递归方式对数据进行分组，这让我有点不知所措。对于不同的用例，似乎有很多很好的例子，但我似乎无法重构代码来满足我的需求。 我可以推断出的中心问题是，在我的map操作符中，我有一个条件返回，它要么是不可观测的，要么是可观测的。有没有一种方法可以重构来解决这种差异？ 理想情况下，这个函数会将原始的“平面”数组按任意数量的列数组，这些列数组是作为参数传入的。 每次满足条件时，它都会以{ key: col_name，elements：...col_elements }的格式追加到一个数组中，其中元素是另一个相同格式的元素数组，或者是一个直接的元素列表。 当只对列进行一次分组时，下面
浏览 22提问于2019-02-27得票数 0
1回答
我需要使用redux-observable按某种顺序分派一些操作，但是，它只需要最后一个动作就可以发出。请参阅示例：
export const fetchClientsEpic = (action$, { dispatch }) =>
action$
.ofType(fetchClients)
.mapTo(fetchClientsPending(true))
.mergeMap(() => {
return ajax
.getJSON('some/get/clients/api')
.map(
浏览 1提问于2018-03-07得票数 2
回答已采纳
1回答
如何在每个动作中发出事件
、、、、
我是RxJS的入门级开发人员，我使用react，redux，react-redux，redux-observable，最重要的是在我的副项目中；
但是我不明白，为什么我的史诗代码块不能像我想的那样工作，希望有人能帮助我。
/* store actions */
export const ACTION_1 = 'ACTION_1';
export const ACTION_2 = 'ACTION_2';
export const ACTION_3 = 'ACTION_3';
/* store reducer */
import * as acti
浏览 6提问于2019-10-20得票数 3
回答已采纳
1回答
我想这个问题以前就有人问过，我试过我能找到的每一个解决办法，但都没有结果。我对RxJ有点陌生，所以如果这看起来很容易的话，我很抱歉。
考虑以下服务：
getSessionsByCampaign(campaignDBID: number) : Observable<CfgCampaignGroup[]>{
return this.http.get<CfgCampaignGroup[]>('http://localhost:4567/api/configuration/sessions?campaign=' + campaignDBID);
}
g
浏览 0提问于2018-06-08得票数 0
回答已采纳
2回答
我现在从承诺转变为可观察的。我正在使用Redux-可观察的我的反应应用程序。基本上，我正在寻找最好的操作符，它将启用多个并发ajax调用，并在所有可观察到的数据成功地完成执行后返回响应。这是我的应用程序的代码片段。
let epicPostAd = (action$, store, {ajax}) =>
action$.ofType(POST_AD)
.debounceTime(1000)
.mergeMap(({ payload }) =>
ajax(generateAjaxRequestSetting(POSTS_URL, 'post'
浏览 5提问于2017-03-30得票数 5
回答已采纳
据我所知，史诗的模式是“行动中，行动外”。
我使用MeteorJS，需要遵循调用Meteor方法与服务器交互的惯例。
看起来像这样：
Meteor.call("<function-name>", ...args, callback)
所以我试着用这样的史诗来处理异步的副作用：
completedSubscribe只是一个动作创建者：const completedSubscribe = result => {type: SUCCEED, result}
import { Observable } from 'rx'
const from
浏览 3提问于2016-11-11得票数 0
回答已采纳
在rxjs6.5中，我在类型记录/角中有这样的场景：
main(){
const properties = ['session', 'user'];
const source: Observable<any> = from(properties);
source
.pipe(
mergeMap(key => this.getKey().map((value) => ({key: key, value: value}))),
浏览 0提问于2019-04-30得票数 7
回答已采纳
在下面的代码中，我很难理解链接调用的顺序是：
function registerDomain(caseWebsiteUrl) {
return this._adminService.registerDomain(caseWebsiteUrl.Url)
.concatMap(registerId => Observable.interval(5000)
.mergeMap(() => this._adminService.getChange(registerId))
.takeWhile((info) => info.Cha
浏览 0提问于2017-07-25得票数 0
回答已采纳
2回答
在订阅中捕获错误是不可能的吗？
、、、、
我使用的是Angular 7，因为外部api返回的值在我期望的值中有空值，所以我试图捕捉抛出的错误。 我似乎不知道在这种情况下我应该做什么。 我有一个调用api的服务。 getObjectValue(param: paramtype): Observable<ObjectValue> {
return this.http.get<objectwithvalues>(environment.baseapiurl + '/api/object/value/'+ param);
} 在消费组件中，我像往常一样订阅 testfunction() {
浏览 24提问于2019-03-28得票数 5
回答已采纳
3回答
可观测数组的可观性
、、、
我在我的Angular4应用程序中使用可观察数据时遇到了以下情况，我无法开始工作:我想要收集我所有预订日期的汇总数据，以便创建一个概述页面。获取所有天数是一个可观察的过程，每天都有一个我必须检索的当天的预订列表-同样是一个可观察的来源。从这个列表中，我计算出一天的总结。所有这些总结我都想在一个可观察的结果中发布。
我已经尝试了很多更复杂的东西，但总是没有等待完成的内部观察点，我得到的是空洞的总结。我已经回到了基础，下面的内容应该是可行的：
getSummaries(): Observable<BookingDaySummary[]> {
return this.bookin
浏览 0提问于2017-12-26得票数 15
1回答
我想使用redux-observable来处理ajax超时，这样如果超时发生(比如10秒后)，它会再次重试请求两次(每次都会触发一个SAVE_RETRYING操作，这样UI就可以通知用户它正在重试)。
对于任何其他类型的错误，或者如果我们已经重试了两次，它应该失败并触发一个SAVE_FAILURE操作。
如果我使用store.dispatch触发SAVE_RETRYING操作，但收到关于这一点的弃用警告，我可以让它工作，并且我有点纠结于如何以正确的方式完成它(将SAVE_RETRYING添加到由epic返回的流中)。
以下是我所拥有的(简化)：
function saveEpic(action
浏览 0提问于2018-08-19得票数 0
回答已采纳
我需要过滤一个对象列表，并从一个string[]成员创建一个不同的可观察流。Typescript 2.9.2 interface Product2 {
id: number;
categories: string[];
}
const products: Product2[] = [
{id: 1, categories: ['abc', 'def']},
{id: 2, categories: ['def', 'xyz']}
];
const products$: Observable<Produc
浏览 22提问于2019-04-12得票数 0
回答已采纳
2回答
我用的是redux，redux-可观察的。
我有以下几点
import { EMPTY, Observable } from "rxjs";
const setCurrentDatastoreIdEpic = (action$, state$): Observable<any> => action$.pipe(
ofType(DatastoreActions.setCurrentDatastoreId),
map((action: {payload: {datastoreId: string}}) => {
if(act
浏览 7提问于2019-12-04得票数 4
回答已采纳
1回答
这应该是一个简单的解决办法，但我似乎不能把它放在一起.
我有一个返回承诺的函数，另一个返回诺言的函数。我需要使用前者的返回值调用后者，但在转换链的末尾也需要这两个值。我已经阅读了一些关于mergeMap和forkJoin的文档，但我似乎无法使用它们来获得我需要的结果：
function getBlob(id: string): Promise<Blob>;
function blobToBase64(imageBlob: Blob): Promise<string>;
// ...
// This is what I tried but I getting Obs
浏览 0提问于2018-03-06得票数 2
回答已采纳
1回答
我想对一个可观察到的值应用一个异步转换函数。
@Injectable
export class ApiService{
constructor(private http: HttpClient){}
getSomething(url): Observable<any>{
return this.http.get(url);
}
}
在上面的代码中，我想对由myFunc发出的值应用一个转换函数myFunc，它返回一个允诺。
通常，我会使用RxJS的map操作符，但是由于转换函数返回一个承诺，所以我无法找到处理它的方法。
例如，让我的函数是：
浏览 3提问于2017-12-07得票数 2
回答已采纳
我对可重测很新，所以我不确定是一个真正的问题还是一个愚蠢的错误。
我试图将测试添加到我为React应用程序编写的史诗中，但我无法对它们进行测试。这就是例子。
我的典型史诗：
const example = action$ =>
action$.pipe(
ofType('my_type'),
mergeMap(() => {
return { type: 'result_type'}
})
);
我试着用最简单的方法测试它：
it('simple te
浏览 5提问于2019-10-11得票数 0
我在redux-observable中有以下史诗
export const landingEpic = action$ => (
action$.ofType('LOAD_USERS').delay(5000).map(() => ({
type: 'USERS_LOADED',
UserList: ['a','b','c','d']
}))
);
到目前为止，我很好，但是我希望epic调度一个'LOADING_USERS‘操作，这
浏览 1提问于2017-04-29得票数 2
2回答
我不知道如何在最后一张图中获得observable 2的值，下面是一个示例
return observable1.pipe(
map((value1: value1) => {
return observable2;
}),
mergeMap((value2: value2) => {
return observable3;
}),
map((value3: value3) => {
// how can i get value 2 inside here?
}),
mapTo(null)
);
浏览 0提问于2018-08-03得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
