如何重启或刷新 Observable？

Question

我有一个 TypeScript/Angular 2 Observable，它在我第一次调用时就完美运行。但是，我有兴趣将多个订阅者附加到同一个可观察对象并以某种方式刷新可观察对象和附加的订阅者。这是我得到的：

query(): Rx.Observable<any> {

return this.server.get('http://localhost/rawData.json').toRx().concatMap(
    result =>
        result.json().posts
    )
    .map((post: any) => {
        var refinedPost = new RefinedPost();
        refinedPost.Message = post.Message.toLowerCase();

        return refinedPost;

    }).toArray();

}

图片显示有一个刷新按钮，当按下该按钮时，会重新执行此可观察对象，并且连接到它的任何订阅者都会获得一组更新的数据。

我怎样才能做到这一点？

Answer 1

我不太了解 Angular2 和 Typescript，但 typescript 是 javascript 的超集，我做出了以下假设（如果我错了请告诉我）应该使以下 javascript 代码工作：

server.getreturns一个承诺（或数组或Rx.Observable）
posts是post

您需要根据该按钮上的点击事件创建一个可观察对象，将点击映射到您的 GET 请求，其余的应该或多或少与您所写的一样。我无法测试它，但它应该遵循这些原则：

// get the DOM id for the button
var button = document.getElementById('#xxx');

// create the observable of refined posts
var query$ = 
    Rx.Observable.fromEvent(button, 'click')
        .flapMapLatest(function (ev) {
                     return this.server.get('http://localhost/rawData.json')
                   })
        .map(function (result){return result.json().posts})
        .map(function (posts) {
                return posts.map(function(post){
                                   var refinedPost = new RefinedPost();
                                   refinedPost.Message = post.Message.toLowerCase();
                                   return refinedPost;
                           })
             })
        .share()

// subscribe to the query$. Its output is an array of refinedPost
// All subscriptions will see the same data (hot source)
var subscriber = query$.subscribe(function(refinedPosts){console.log(refinedPosts)})

一些解释：

每次点击都会产生对 server.get 的调用，其中 returns 可观察兼容类型（数组、承诺或可观察）。返回的 observable 被展平以从该调用

result

因为用户可以点击很多次，每次点击都会产生它的数据流，而我们只对最近一次点击的结果感兴趣（我在这里也做的另一个假设），所以我们使用运算符 flatMapLatest，它将仅对最新点击生成的可观察对象执行 flatMap
我们提取 post posts 的数组并从中创建一个 refinedPost 的数组。最后，每次点击都会产生一个 refinedPost 的数组，我认为这就是你想要的
我们共享这个可观察对象，因为您提到您将有多个订阅者，并且您希望所有订阅者看到相同的数据。

让我知道我的假设是否正确，是否对你有用。

另外我推荐你看看https://gist.github.com/staltz/868e7e9bc2a7b8c1f754

除了很好地提醒概念之外，它还解决了与您的问题非常相似的刷新服务器调用问题。

如何重启或刷新 Observable？

How to restart or refresh an Observable?

javascript

rxjs

typescript

angular