javascript - Rx 如何在 web 上真正工作(客户端)

Question

我已经在 Rx CodePlex 完成了介绍部分。页。我看过video of the guy with CascadiaJS .我发现了如何使用 RxJS 库。我有一个问题，关于它如何帮助我处理现有的 Ajax 应用程序，以及我必须在服务器端和客户端进行哪些更改才能充分利用 RxJS。

场景我有一个使用 ASP.NET Web API 编写的 REST 服务。该服务目前有一个方法，它接受一个坐标数组并返回另一个坐标数组。所以调用很简单，就是这样。

 $.ajax({
    url: "http://www.myservice.com/service1/",
    type: "POST",
    data: JSON.stringify(params),
    contentType: "application/json;charset=utf-8",
    success: handle_success,
    error: handle_failure,
    OPTIONS: null,
});

现在上面的调用只是简单地调用了一个 REST 服务并对结果的输出方式采取适当的操作。

有了 Rx，我听到了“推”而不是“拉”的口头禅。我们如何将“Push”放入上面的示例中？我是否要将我的 REST 服务更改为监听 TCP 套接字，我的网页将保持连接(或建立 Keep-Alive 连接)并且新值将被“推送”。或者这只是一个如上所述的服务调用，但成功/错误将通过 Observable 进行“引导”，一旦调用完成，该 Observable 的工作就完成了？

Answer 1

即使不担心更改服务器以推送到客户端，RxJs 也可以帮助您在客户端组合异步操作。

例如，如果您将 ajax 调用建模为可观察对象:

// each time you subscribe to service, it will execute the ajax call and send back the result
var service = Rx.Observable.defer(function () {
    return $.ajax({
        url: "http://www.myservice.com/service1/",
        type: "POST",
        data: JSON.stringify(params),
        contentType: "application/json;charset=utf-8"
    });
});

// Now fun with Rx

// just call the service like in your OP example:
service.subscribe(handle_success, handle_failure);

// poll the service every 5 seconds
var pollInterval = Rx.Observable.empty().delay(5000);
service
    .concat(pollInterval)
    .repeat()
    .subscribe(success, failure);

// run the service whenever user clicks Refresh
$('#refresh')
    .onAsObservable('click')
    .flatMap(function () { return service; })
    .subscribe(success, failure);

// same as above, but ignore it when user clicks too fast (e.g. faster than 1 second)
$("#refresh")
    .onAsObservable('click')
    .debounce(1000)
    .flatMap(function () { return service; })
    .subscribe(success, failure);