angular - typescript : return Array as Observable

Question

如何在 getTodoItems() 中返回一个数组作为 Observable？

它是 Promise<Itodo[]>我用了Promise.Resolve(TodoItems)返回数组。但是当我将其更改为使用 Observable 时而不是 Promise ，我不知道如何返回数据，无法让它工作。

我试过了 Observable.of(TodoItems)但它不知道 .of功能。

无论我尝试什么，我都会不断收到这些错误。你能帮我吗？谢谢。

import { Injectable } from '@angular/core';
import { Http, Response } from '@angular/http';

import { Observable } from 'rxjs/Observable';
import 'rxjs/add/operator/map';
import 'rxjs/add/observable/fromArray';

import { Itodo } from './todo'

const TodoItems: Itodo[] = [
    { todoId: 11, description: 'Mr. Nice' },
    { todoId: 12, description: 'Narco' },
    { todoId: 13, description: 'Bombasto' }
]

@Injectable()
export class TodoService {


    constructor(private _http: Http) {
    }

    getTodoItems(): Observable<Itodo[]> {

        return TodoItems.map((items => Itodo[]) => <Itodo[]>items);
    }

    addNewTodo(model: Itodo) {        
        TodoItems.push(model);
    }

    getTodoItem(id: number): Observable<Itodo> {
        return this.getTodoItems()
            .map((items: Itodo[]) => items.find(p => p.todoId === id));    }
}

Answer 1

Observable.of是您正在寻找的正确方法。在我的项目中，我使用 rxjs5-beta6 和 import { Observable } from 'rxjs/Observable';足以使用 of方法。根据您的项目，您可能需要显式导入 of方法。

如果都失败了，你可以尝试使用Observable.from(TodoItems)甚至尝试创建您自己的 observable 来返回您的值。

例如

Observable.create((observer: Subscriber<any>) => {
observer.next(TodoItems);
observer.complete();
});