Làm thế nào để tạo ra một Observable từ dữ liệu tĩnh tương tự như http một trong Angular?

Question

Tôi gặp một dịch vụ mà có phương pháp này:

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()); 
     } 
    } 
} 

trong constructor của thành phần Tôi đăng ký như thế này:

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) 
    ); 
    } 
} 

này hoạt động nếu một đối tượng xuất phát từ server..but Tôi cố gắng để tạo ra một quan sát mà sẽ làm việc với các cuộc gọi hiện tại() gọi cho một chuỗi tĩnh (điều này xảy ra khi testModelService.fetchModel() không được đưa ra một uuid) để có xử lý liền mạch trong cả hai trường hợp. Điều này có thể không?

Answer 1

Có lẽ bạn có thể thử sử dụng phương pháp of của lớp Obserable:

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()); 
    } 
} 

Answer 2

Mọi thứ dường như đã thay đổi kể từ góc 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()); 
    } 
} 

Chức năng .next() sẽ được kêu gọi của bạn người đăng kí.

Answer 3

Đây là cách bạn có thể tạo một quan sát đơn giản cho dữ liệu tĩnh.

let observable=Observable.create(observer => { 
      setTimeout(() => { 
      let users = [{username:"balwant.padwal",city:"pune"}, 
         {username:"test",city:"mumbai"}] 
      observer.next(users); // This method same as resolve() method from Angular 1 
      console.log("am done"); 
      observer.complete();//to show we are done with our processing 
      // observer.error(new Error("error message")); 
      }, 2000); 

     }) 
    to subscribe to it is very easy 

    observable.subscripe((data)=>{ 
    console.log(data); // users array display 
    }); 

Tôi hy vọng câu trả lời này hữu ích. Chúng tôi có thể sử dụng cuộc gọi HTTP thay vì dữ liệu tĩnh.