如何使用rx.js发送多个http请求？

Question

我正在尝试rx.js,我正在尝试提出多个http请求.这是observable我设置的http请求.

function httpGet(url) {
    return Observable.create(function forEach(observer) {
        var cancelled = false;
        axios.get(url).then(function(res) {
            if(!cancelled) {
                observer.onNext(res);
                observer.onCompleted();             
            }
        });

        return function dispose() {
            cancelled = true;
        }
    })
}

我正在尝试提出多个http请求,但我的结果更多Observable.这是subscribe:

var array = ['http://localhost:4444/text/88', 'http://localhost:4444/other/77'];

var source = Rx.Observable.fromArray(array).map(httpGet);

var subscription = source.subscribe(
    function (x) {
        console.log(x);
    },
    function (err) {
        console.log('Error: ' + err);
    },
    function () {
        console.log('Completed');
});

这是我的结果.

AnonymousObservable { source: undefined, __subscribe: [Function: forEach] }
AnonymousObservable { source: undefined, __subscribe: [Function: forEach] }
Completed

我知道我正在接受它Observable,如果我forEach通过它们,那么我会得到结果,但我错过了将其转换为data而不是转换的正确方法Observable.我究竟做错了什么？

Answer 1

这应该够了吧:

var array = ['http://localhost:4444/text/88', 'http://localhost:4444/other/77'];

var source = Rx.Observable.fromArray(array).concatMap(httpGet);

function httpGet(url) {
  return axios.get(url);
  }
var subscription = source.subscribe(
    function (x) {
        console.log(x);
    },
    function (err) {
        console.log('Error: ' + err);
    },
    function () {
        console.log('Completed');
});

一些解释:

• 可观察的是一系列价值观.观察者是一个处理这些值的三管齐下的对象.
• 你想要的是将数组(源)转换为html序列(从获取URL获得).您拥有的是:
  • 用于从外部源创建可观察对象的一组函数:cf.https://github.com/Reactive-Extensions/RxJS/blob/master/doc/gettingstarted/categories.md,部分Converting events or asynchronous patterns to observable sequences, or between Arrays and observable sequences.
  • 一组运算符,允许将这些源序列带入您制作的序列中(与上面相同的链接).
• 然后,您想订阅生成的序列并使用它们执行某些操作.这是subscribe您定义观察者的功能.
• 所以在这里你得到你的数组值序列,用map运算符产生一系列的promises ,但实际上你将使用concatMap运算符以与数组值相同的顺序输出promise promise值.concatMap可以将一个observable,一个数组/可迭代或一个promise作为其参数,并将输出包含在它返回的observable中的那些对象的值序列.因此,您没有一系列的承诺,而是通过承诺(即您获取的html内容)解决了一系列值.如果您对保持源的初始排序不感兴趣,您也可以使用该flatMap运算符.参看 https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/concatmap.md和https://github.com/Reactive-Extensions/RxJS/blob/master/doc/ API /型芯/运营商/ selectmany.md
• 然后你订阅它,并处理这些值

因此,这基本上是一般过程,您采用源序列,通过明智地选择运算符将其转换为您选择的序列,然后使用您的观察函数逐个处理这些值.另外,请注意,promise类似于observable,而某些(大多数？)Rxjs运算符会将它们视为这样,因此您通常不必使用它then来获取已解析的值.

最后一件事,Rx.Observable.fromArray似乎被弃用了赞成Rx.Observable.from:cf.https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/fromarray.md