使用 observable 通过 http 检索数据一次，然后保存该值以供重用

Question

在 Scala 中，有Futures 的概念，当一个值准备好时，它会在将来保存。我正在努力寻找类似的东西。

例如，我想访问“用户”数据。当我第一次访问这个时，我想向服务器发送一个请求以获取数据，但是对于所有后续访问，我希望能够使用存储的值。

以下代码尝试实现类似的功能。它不保证对服务器的调用只会发生一次。

抱歉，TypeScript 中有以下内容：

class AuthenticationService {

  http: Http = Some Http Helper...

  user: Observable<User> = this.http.get("www.example.com/logged-in-user")
    .map(data => {
      let userObject = data.json().user
      this.user = Observable.of(userObject)
      return userObject
    })
}

有更好的方法吗？

Answer 1

如果我理解正确，您搜索的是Rx.BehaviorSubject。

它将存储最后一个值并发送给任何未来的订阅者：

import Rx from 'rxjs/Rx'; // just for development, use a more specific when done

class AuthenticationService {

  http: Http = Some Http Helper...

  user: Observable<User> = this.http.get("www.example.com/logged-in-user")
    .map(data => {
      let userObject = data.json().user
      this.user = new Rx.BehaviorSubject(userObject)
      return userObject
    })
}

单独的功能示例：

/* Initialize with initial value of 42 */
var subject = new Rx.BehaviorSubject(42);

function subsc(title) {
  subject.subscribe(
    (x) => console.log(title + ' Next: ' + x.toString()),
    (err) => console.log(title + ' Error: ' + err),
    () => console.log(title + ' Completed')
  );
}

subsc("1st"); // Initial Next: 42
subsc("2nd"); // Initial Next: 42

subject.next(56);

subsc("3rd");  // Initial Next: 56

subject.complete();