zoukankan      html  css  js  c++  java
  • [RxJS] How To get the results of two HTTP requests made in sequence

    switchMap can chain two HTTP requests together, creating one request based on the results of the first request.

    But the result observable did not have the data of the first request, instead it only had access to the data of the second HTTP request.

    If we would like to have both the data of the first HTTP request and deliver it together with the data of the second request, we could use a selector function (notice the second argument passed to switchMap):

    sequentialRequests() {
    
    const sequence$ = this.http.get<Course>(
                '/courses/-KgVwEBq5wbFnjj7O8Fp.json')
        .switchMap(course => {
            course.description+= ' - TEST ';
            return this.http.put('/courses/-KgVwEBq5wbFnjj7O8Fp.json', course)
        },
        (firstHTTPResult, secondHTTPResult)  => 
                   [firstHTTPResult, secondHTTPResult]);
    
    sequence$.subscribe(
        values => console.log("result observable ", values) 
    );
        
    }

    Other example:

    //emit immediately, then every 5s
    const source = Rx.Observable.timer(0, 5000);
    //switch to new inner observable when source emits, invoke project function and emit values
    const example = source.switchMap(() => Rx.Observable.interval(2000), (outerValue, innerValue, outerIndex, innerIndex) => ({outerValue, innerValue, outerIndex, innerIndex}));
    /*
        Output:
        {outerValue: 0, innerValue: 0, outerIndex: 0, innerIndex: 0}
        {outerValue: 0, innerValue: 1, outerIndex: 0, innerIndex: 1}
        {outerValue: 1, innerValue: 0, outerIndex: 1, innerIndex: 0}
        {outerValue: 1, innerValue: 1, outerIndex: 1, innerIndex: 1}
    */
    const subscribe = example.subscribe(val => console.log(val));
  • 相关阅读:
    kettle-学习参考
    spring retry 重试机制完整例子
    一个四五年的Java开发程序员,该准备哪些去面试?
    Java之io nio aio 的区别
    Java对象的存活判断
    Java+微信支付(下预购单+回调+退款+查询账单)
    Java +支付宝 +接入
    关于MQ 消息队列的通俗理解和 rabbitMQ 使用
    java 对接芝麻信用 -用芝麻私钥解密错误
    mysql 乐观判断 校验
  • 原文地址:https://www.cnblogs.com/Answer1215/p/7418632.html
Copyright © 2011-2022 走看看