如何从静态数据中创建一个类似于http的可观察数据？

Question

我有一个服务，有这个方法：

export class TestModelService {

    public testModel: TestModel;

    constructor( @Inject(Http) public http: Http) {
    }

    public fetchModel(uuid: string = undefined): Observable<string> {
        if(!uuid) {
            //return Observable of JSON.stringify(new TestModel());
        }
        else {
            return this.http.get("http://localhost:8080/myapp/api/model/" + uuid)
                .map(res => res.text());
        }
    }
}

在组件的构造函数中，我按如下方式订阅：

export class MyComponent {
   testModel: TestModel;
   testModelService: TestModelService;

   constructor(@Inject(TestModelService) testModelService) {
      this.testModelService = testModelService;

      testService.fetchModel("29f4fddc-155a-4f26-9db6-5a431ecd5d44").subscribe(
          data => { this.testModel = FactModel.fromJson(JSON.parse(data)); },
          err => console.log(err)
      );
   }
}

如果一个对象来自服务器，但我试图创建一个可观察的，将与给定的订阅（）调用静态字符串（这发生时testModelService.fetchModel（）不接收一个uuid），所以在这两种情况下都有无缝处理。

Answer 1

自Angular 2.0.0以来，情况似乎发生了变化

import { Observable } from 'rxjs/Observable';
import { Subscriber } from 'rxjs/Subscriber';
// ...
public fetchModel(uuid: string = undefined): Observable<string> {
  if(!uuid) {
    return new Observable<TestModel>((subscriber: Subscriber<TestModel>) => subscriber.next(new TestModel())).map(o => JSON.stringify(o));
  }
  else {
    return this.http.get("http://localhost:8080/myapp/api/model/" + uuid)
            .map(res => res.text());
  }
}

将在您的订阅服务器上调用.next（）函数。

Answer 2

匿名用户

截至2018年7月和发布的RxJS 6，从值获取可观测的新方法是导入运算符的，如下所示：

import { of } from 'rxjs';

然后从值中创建可观察对象，如下所示：

of(someValue);

请注意，您过去必须像当前接受的答案中那样执行Observable.of（某些值）。这里有一篇关于其他RxJS 6更改的好文章。

Answer 3

也许您可以尝试使用可观察类的的方法：

import { Observable } from 'rxjs/Observable';
import 'rxjs/add/observable/of';

public fetchModel(uuid: string = undefined): Observable<string> {
  if(!uuid) {
    return Observable.of(new TestModel()).map(o => JSON.stringify(o));
  }
  else {
    return this.http.get("http://localhost:8080/myapp/api/model/" + uuid)
            .map(res => res.text());
  }
}