Angular 2.0 - 将 promise 链转换为 Observables

Question

我正在将 NG 1.X 服务转换为 NG 2.0。

我的 NG 1.X 服务有承诺链（简化）：

dataService.search = function(searchExp) {
      return this.getAccessToken()
      .then(function(accesstoken) {
        var url = $interpolate('https://my-api-url?q={{search}}&{{accesstoken}}')({search: searchExp, accesstoken: accesstoken});
        return $http({
          url: url,
          method: 'GET',
          cache: true
        });
      }).then(function(response) {
        return response.data;
      });
    };

我想将 search 服务转换为 Angular 2.0 服务，使用 http 并返回 Observable。我更喜欢保持 getAccessToken 服务不变，作为 NG 1.X 服务，returns 一个承诺。

我正在考虑在旧 "promise" 服务上使用 Observable.fromPromise。

我该怎么做？我如何链接这两个？

编辑:

澄清一下，我希望它是这样的：

dataService.search = function(searchExp) {
 return this.getAccessToken()
        .then(function(accesstoken) {
           //Here I want to use:
           // this.http.get(url).subscribe(() => ...)
          });
        };

Answer 1

你应该制作 search 方法 return Observable 对象。像这样：

dataService.search = function(searchExp) {

    var promise = new Promise((resolve, reject) => {
        this.getAccessToken()
            .then(accesstoken => {
                return this.http.get('data.json')
                    .map(response => response.json())
                    .subscribe(data => resolve(data), err => reject(err))
            })
    });

    return PromiseObservable.create(promise); // Observable.fromPromise(promise)
};

Answer 2

我将@dfsq 的 Plunker 转换为 beta.0。 map() 如果不导入它似乎不再可用（但我们这里不需要它）。

import {Component, Injectable} from 'angular2/core';
import {HTTP_PROVIDERS, Http} from 'angular2/http';
import {PromiseObservable} from 'rxjs/observable/fromPromise';

@Injectable()
export class DataService {
  constructor(private _http: Http, private _accessService: AccessService) {} 
  search(searchExp) {
    var promise = new Promise((resolve, reject) => {
      this._accessService.getAccessToken()  // see Plunker for AccessService
        .then(accessToken => {
          return this._http.get('data.json')  // use accessToken here
            .subscribe(res => resolve(res.json()), err => reject(err));
        });
    });
    return PromiseObservable.create(promise);
  }
}
@Component({
  selector: 'my-app',
  providers: [HTTP_PROVIDERS, AccessService, DataService],
  template: `<h2>Data loaded</h2><pre>{{data | json}}</pre>
  `
})
export class AppComponent {
  data: any;
  constructor(private _dataService: DataService) { 
    console.clear();
  } 
  ngOnInit() {
    this._dataService.search('test')
      .subscribe(res => {
        this.data = res; 
      });
  }
}

beta.0 Plunker

Angular 2.0 - 将 promise 链转换为 Observables

Angular 2.0 - converting promise chaining to Observables

javascript

reactive-programming

rxjs

angularjs

angular