使用.next方法时出错

Question

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

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

我有这个错误:

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

请问.接下来方法可观察到的数据流会奏效吗？

Answer 1

该函数next不是Observable的函数.它是观察者的一个功能.

您可以使用同时充当Observer和Observable的Subject.所以像这样:

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

由于您有一个数组Message,您还必须使用next数组.

有关更多信息,请访问:http://reactivex.io/documentation/subject.html