TypeError : 스트림이 예상되는 곳에 잘못된 개체를 입력했습니다.

Question

다음 코드가 작동합니다. 그것은 아약스 요청을 수행하고 다음 번에이 작업을 호출

export const loadThingsEpic = action$ => { 

    return action$.ofType(LOAD_THINGS) 
    .mergeMap(({things}) => { 
     const requestURL = `${AppConfig.serverUrl()}/data/things`; 
     return ajax.getJSON(requestURL)).map(response => { 
     return finishLoadingThings(response); 
     }).map(() => { 
     return sendNotification('success'); 
     }); 
    }) 
    .catch(e => { 
     return concat(of(finishLoadingThings({ things: {} })), 
        of(sendNotification('error'))); 

    }); 
}} 

하지만이 코드는하지 않습니다

export const loadThingsEpic = action$ => { 

    return action$.ofType(LOAD_THINGS) 
    .mergeMap(({things}) => { 
     const requestURL = `${AppConfig.serverUrl()}/data/things`; 
     return ajax.getJSON(requestURL).switchMap(response => { 
     return concat(of(finishLoadingThings(response)), 
         of(sendNotification('success'))); 
     }); 
    }) 
    .catch(e => { 
     return concat(of(finishLoadingThings({ things: {} })), 
        of(sendNotification('error'))); 
    }); 
} 

내가 함께이 작업을 병합하는 switchMap에 의해지도를 교체했습니다 (다른 많은 게시물에서 볼 수 있듯이). 예외가 발생하면 catch에서 작동합니다. 코드에 무슨 문제가 있는지 궁금합니다. Map, swicthMap 및 mergeMap과 같은 사용시기를 실제로 파악할 수 없기 때문에 추측하고 있습니다.

sendNotification에와 finishLoadingthings 반환 조치 개체 :

export function finishLoadingThings(data: any) { 
    return { 
    type: FINISH_LOADING_THINGS, 
    data, 
    }; 
} 

감사합니다!

Answer 1

제공된대로 코드가 의도 한대로 작동하는 것으로 보입니다. https://jsbin.com/becapin/edit?js,console ajax가 성공하거나 실패 할 때 "스트림이 예상되는 곳에 유효하지 않은 개체"오류가 표시되지 않습니다.

오류가이 코드에서 발생 했습니까?

별도의 노트에

---

, 당신은 Observable.of 인수 개수를 임의로 설정할 수 있습니다 듣고 행복 할 수도, 각각은 다른 후 방출됩니다. 그래서 대신의 :

.switchMap(response => { 
    return concat(of(finishLoadingThings(response)), 
       of(sendNotification('success'))); 
}); 

당신은이 작업을 수행 할 수 있습니다

이 비록 버그가 발생하지 않았을

.switchMap(response => { 
    return of(
    finishLoadingThings(response), 
    sendNotification('success') 
); 
}); 

, 그냥 청소기입니다.

Answer 2

나는 mergeMap과 같은 레벨에서 switchMap을 수행하여 문제를 해결할 수있다. 이와 같이 :

export const loadThingsEpic = action$ => { 

    return action$.ofType(LOAD_THINGS) 
    .mergeMap(({things}) => { 
     const requestURL = `${AppConfig.serverUrl()}/data/things`; 
     return ajax.getJSON(requestURL).switchMap(response => { 
     return of(response); 
     }); 
    }) 
    .switchMap((res) => { 
     return concat(of(finishLoadingThings(res.value)), 
         of(sendNotification('success'))); 
    }) 
    .catch(e => { 
     return concat(of(finishLoadingThings({ things: {} })), 
        of(sendNotification('error'))); 
    }); 
} 

아직 얻지 못했습니다.