angularjs - RxJS Observables，什么时候退订？

我有几个关于角度的问题。我最近开始尝试使用Angular，真的不知道什么时候应该取消订阅，显然建议使用AsyncPipe，但在某些情况下没有办法使用它。
如果我订阅了服务中的http请求，那么observate是自己取消订阅，还是在整个应用程序生命周期内保持不变？
当我订阅（不使用异步管道）组件中的http请求时，我可以在ngondestroy生命周期挂钩中手动取消订阅，这很好，但在我的例子中，我有一个submit方法来创建帐户
account.component.html网站

<account-item>
 *ngFor="let account of collection$"
 [data]="account"
</account-item>

帐户.component.ts

public collection$: Observable<Account[]>;
private subscription: Subscription;

 constructor(
  private service: AccountService
 ) {}

 ngOnInit() {
   this.collection$ = this.service.getAll()
 }

 createAccount(obj) {
  this.subscription = this.service.create(obj)
   .subscribe(
    success => this.collection$ = this.service.getAll(),
    error => Observable.throw(error)
  );
}

ngOnDestroy() {
 this.subscription.unsubscribe();
}

据我所知，订阅现在是持久的，直到我的accountcomponent被销毁，但是这里是否有方法使用asyncpipe，或者我最好订阅服务本身？
我读过一些关于有限和无限可观测的东西，但还没有真正理解什么时候可观测是有限的。
我面临的另一个问题是，在success => this.collection$ = this.service.getAll()中，当我使用ChangeDetectionStrategy.OnPush时，我的ui不会更新为新的帐户列表，但在ChangeDetectionStrategy.Default中工作得很好。
这是获取帐户数据的服务方法

 getAll() {
  return this.http.get(ENDPOINT_ACCOUNT)
    .map((response: Response) => response.json().data)
}

最佳答案

在更全球化地处理可观察和函数编程时，您需要考虑的是，您不描述事情是如何完成的，而是描述事情是什么。
在您的示例中，集合一方面是从服务的初始获取，另一方面是可能发生的所有更新的组合，因此如果要避免订阅组件，可以执行以下操作：

class Foo {
  public collection$: Observable < Account[] > ;
  private createAccount$ = new Subject<Account>();

  constructor(
    private service: AccountService
  ) {}

  ngOnInit() {
    let initialAccounts = this.service.getAll().share();
    let accountUpdate = initialAccounts.switchMap(()=>this.createAccount$.switchMap(account=>{
      return this.service.create(account).switchMap(()=>this.service.getAll())
    }))
    this.collection$ = Observable.merge(initialAccounts,accountUpdate);
  }

  createAccount(obj:Account) {
    this.createAccount$.next(obj);
  }

}

我们在这里使用merge运算符从initialAccounts或createAccount$获取数据。把你的观察结果结合起来订阅一次总是一件好事，因为这样你就不必强制管理你的订阅了。
事实上，大多数时候，你根本不需要subscribe()。