PROSAGA码农传奇-Angular-改变流源

<div class =“post-text”itemprop =“text”>
  
    你可以用一个
     <code>
 Subject
 </code>
     （
    <a href="http://reactivex.io/rxjs/class/es6/Subject.js@Subject.html" rel="nofollow noreferrer">
      http://reactivex.io/rxjs/class/es6/Subject.js~Subject.html
    </A>
    ）
  
  
    我创建了一个非常简化的stackblitz来展示它是如何工作的

<a href="https://stackblitz.com/edit/angular-zyvkpu?file=src%2Fapp%2Fapp.component.ts" rel="nofollow noreferrer">
      https://stackblitz.com/edit/angular-zyvkpu?file=src%2Fapp%2Fapp.component.ts
    </A>
  
  
    查看控制台输出以进行验证。
  
  
    这是相关的代码部分（适用于您的情况，而不是来自stackblitz的1：1）
  
   <pre class="lang-js prettyprint-override">
 <code>
 @Injectable()
export abstract class PageDetailsAbstract<T> implements OnInit {
 object: string;
 id: number;
 details$: Subject<T> = new Subject<T>();

constructor(
    protected entitiesSelectors: EntitiesSelectors) {
  }

ngOnInit() {
    this.route.params
      .pipe(
        map(resp => +resp.id),
      )
      .subscribe(resp => {
        this.id = resp;
        this.adopt();
      });
  }

protected adopt() {
    if (this.id) {
      this.entitiesSelectors.details(this.object, this.id).subscribe((detail: T) => {
        this.details$.next(detail);
    });
  }
}

</code>
 </pre>
  
    我个人会重新调整一下代码。
这是一个更清洁的赌注，因为你不会嵌入多个来电
     <code>
 subscribe
 </code>
     并且你不依赖（至少没有那么多）
     <code>
 this.id
 </code>
     它存在于rxjs流程之外。
  
  
    至
  
   <pre class="lang-js prettyprint-override">
 <code>
 @Injectable()
export abstract class PageDetailsAbstract<T> implements OnInit {
 object: string;
 id: number;
 details$: Subject<T> = new Subject<T>();

constructor(
    protected entitiesSelectors: EntitiesSelectors) {
  }

ngOnInit() {
    this.route.params
      .pipe(
        mergeMap((resp: any) => {
         return this.adopt(+resp.id);
      }))
      .subscribe((detail: T) => {
        this.details$.next(detail);
      });
  }

protected adopt(id: number): Observable<T> {
 if (this.id) {
 return this.entitiesSelectors.details(this.object, this.id);
 }
 else {
 return of(null); // or whatever is appropriate in your case (e.g. EMPTY or something)
 }
}

</code>
 </pre>
  
    你的孩子班级会保持不变。
  
  
    的
      为什么
    </强>
     
    
至于为什么你的例子不起作用：
我想是因为
     <code>
 details$
 </code>
     是一种冷漠的观察。 （
    <a href="https://blog.thoughtram.io/angular/2016/06/16/cold-vs-hot-observables.html" rel="nofollow noreferrer">
      https://blog.thoughtram.io/angular/2016/06/16/cold-vs-hot-observables.html
    </A>
    ）
  
  
    当你重新分配
     <code>
 details$
 </code>
     你创建一个新的observable，之前订阅的没有意义，因为它是另一个observable。您需要重新订阅。
  
  
     <code>
 Subject
 </code>
     是一个热门观察。
也许你也可以使用类似的东西
     <code>
 publish
 </code>
     要么
     <code>
 share
 </code>
     把你的冷观察变成一个热的观察者。
  
</DIV>