我们应该订阅一个 void 函数吗？如何订阅？

Question

Promises 很容易，因为我可以告诉函数 void 函数的返回类型是 Promise（我希望我是对的）。

我想对 Observables 做同样的事情，所以它会是这样的：

import {Observable, Subject} from "rxjs/Rx"

...
private personArray:Person[] = PERSONS; ///some persons in other file.
...

///This fucntion remove one person from my service.

public remove(id:number):Observable<void> {
    this.personArray = this.personArray.filter(person1=>person1.id !== id);
    return Observable.from(); ???
  }

1. 订阅者不知道第一行是否引发错误。我确信有更好的方法可以做到这一点，我很高兴看到任何其他对此的不满。
2. 我怎样才能使这段代码工作？

谢谢。

Answer 1

如果您只想要 OnCompleted 消息，请使用 Observable.empty()。如果发生错误，可以使用Observable.throw(...)：

public remove(id:number):Observable<void> {
  try {
    this.personArray = this.personArray.filter(person1=>person1.id !== id);
    return Observable.empty();
  } catch (e) {
    return Observable.throw(e);
  }
}

或者，您可以使用.defer()。如果您的函数抛出异常，则会（自动）抛出 OnError：

public remove(id:number):Observable<void> {
  return Observable.defer(() => {
    this.personArray = this.personArray.filter(person1=>person1.id !== id);
    return Observable.empty();
  });
}

Answer 2

由于您不能真正使用void，并且类型并不重要，因为没有人会尝试解释任何值，所以只需使用any：

public remove(id:number):Observable<any> {
    this.personArray = this.personArray.filter(person1=>person1.id !== id);
    return Observable.empty<any>();
}