RXJS 订阅方法中的主题

Question

我已经克隆了一个基于 RXJS 的 Github repo，带有 angular 2+。 帮我理解 this.createTodo$.subscribe(this.create$) 的含义 在下面的代码中。

我能够理解，这里我们正在尝试订阅 createTodo$ observable。在订阅方法中，我总是设置数据，但是什么 this.create$ 表示。这里 create$ 是一个 Subject。

请找到进行此订阅的服务代码。

import { Injectable } from '@angular/core';
import { BehaviorSubject, Observable ,Subject} from 'rxjs';
import {  itemmodel } from './models/listmodel';
import {scan,map} from 'rxjs/operators';

type TodosOperation = (todos: itemmodel[]) => itemmodel[];
const initialTodos=[];

@Injectable({
  providedIn: 'root'
})

export class SharedserviceService {
  public data;
  create$: Subject<itemmodel> = new Subject<itemmodel>();
  createTodo$: Subject<itemmodel> = new Subject<itemmodel>();
  todos$:Observable<itemmodel[]>;
  public item = new BehaviorSubject([]);
  update$: BehaviorSubject<TodosOperation> = new BehaviorSubject<TodosOperation>((todos: itemmodel[]) => todos);

  constructor(){ 
    this.todos$ = this.update$.pipe(scan((todos: itemmodel[], operation: TodosOperation) => operation(todos), initialTodos));

    this.create$.pipe(map((todo) => {
      return (todos) => todos.concat(todo);
    })).subscribe(this.update$);

    this.createTodo$.subscribe(this.create$);
  }

  public additem(item){
    this.createTodo$.next(item);
  }

}

Answer 1

这是一个命名约定。使用美元符号 ($) 表示该变量是一个流（观察者）。

要观察流，你订阅它