rxjs - 使用 .next 方法时出错

Question

这几天我一直在尝试使用.next 方法来添加数据。在尝试这个:

messages: Observable<Message[]>;
const newMessage = new Message(objMessage);
messages.next(newMessage);

我有这个错误:

Property 'next' does not exist on type 'Observable<Message[]>'.

.next 方法在 Observable 流中运行良好吗？

Answer 1

next 函数不是 Observable 上的函数。这是 Observer 上的一个函数。

你可以使用一个 Subject 同时充当 Observer 和 Observable。所以像这样:

const messages = new Subject<Message[]>();
const newMessage = new Message(objMessage);
messages.next([newMessage]);

由于您有一个 Message 数组，您还必须对一个数组使用 next。

更多信息:http://reactivex.io/documentation/subject.html