RxJS Subject 从来没有推送过第一个 next

Question

我在构建主题和评论系统方面遇到问题。它工作正常，但是在有人发表另一条评论之前，发布的第一条评论永远不会出现，此后所有其他 cmets 都可以正常工作。我曾尝试使用 BehaviourSubject 给出初始值为 null 或 "" 和 ReplaySubject 但我认为我可能会遗漏这些工作方式的某些内容，无论如何要让这项工作实时进行，即当用户推送评论时它会转到服务器并且无需立即提交第二条评论即可重新添加到堆栈中？

import { Injectable } from '@angular/core';
import { Observable } from "rxjs/Observable"
import { BehaviorSubject } from "rxjs/BehaviorSubject"
// import {Subject} from "rxjs/Subject"
import { ServerAPI } from '../serverapi';
import { ReplaySubject } from 'rxjs/internal/ReplaySubject';
import { Subject } from 'rxjs/Subject';

@Injectable({
    providedIn: 'root'
})
export class Comments {
    private _comments = new Subject<any[]>();
    $comments: Observable<any> = this._comments.asObservable();

    constructor(private api: ServerAPI) {
        this.$comments.subscribe(() => {
            console.log('comments sub\'d');
        });
    }

    async comment(threadID: string, commentData: any): Promise<any> {
        await this.api.postComment(threadID, commentData);
        const fetchComments = await this.api.getComments(threadID);
        this._comments.next(fetchComments);
    }
}

在我的模板中，我通过订阅 li 收到了 cmets

this.comment.$comments.subscribe(chats => {
    this.CommentData = chats;
});

Answer 1

你需要有一个功能来订阅这样的主题

getData() {
    return this._comments.asObservable();
}

这就是您在组件中订阅 getData() 的方式

this.service.getData().subscribe(x=> {
   console.log(x);
});

像你现在所做的那样订阅构造函数只会执行一个

constructor(private api: ServerAPI) {
    this.$comments.subscribe(() => {
        console.log('comments sub\'d');
    });
}