1

私は関数を持っていますloadMessages、私はそれを返したいですObservable。

  loadMessages(chatId: string): Observable<Message[]> {
    console.log('1');

    this.autorun(() => {
      const handle = this.subscribe('messages', chatId);

      if (handle.ready()) {
        console.log('2');

        const messages = Messages.find().fetch();
        return Observable.of(messages);  // here return is not for this function, which is useless
      }
    });

    console.log('3');  // I don't want this line run immediately

    // I wish I can return here, but I cannot
  }

機能レベルに戻るにはどうすればよいですか?

また、現在の順序は 1 -> 3 -> 2 です。1 -> 2 を実行し、データを取得するまで待機する方法はありますか?

4

1 に答える 1

3

次のようなことを試すことができます：

loadMessages(chatId: string): Observable<Message[]> {
  console.log('1');

  return Observable.create(observer => {
    this.autorun(() => {
      const handle = this.subscribe('messages', chatId);

      if (handle.ready()) {
        console.log('2');

        const messages = Messages.find().fetch();
        observer.next(messages)
      }
    });
  });
}

非常に簡単な例はこちらhttp://plnkr.co/edit/GADtB8QCTnNubtRu9SFv?p=preview

于 2016-06-26T06:56:47.270 に答える