In my code, I have a variable called 'messages' which stores messages from a conversation:
messages: Observable<Message[]>;
To populate the 'messages' variable, I do the following:
const newMessage = new Message(objMessage);
newThread.messages = Observable.of([newMessage]);
I want to automatically update my 'lastMessage' variable to always hold the latest message in the 'messages' variable:
lastMessage: Message = null;
Here is what I attempted, but it's not working as expected:
const messagesThread: Thread = threads[message.thread.id];
if (!messagesThread.lastMessage ||
messagesThread.lastMessage.date < message.date) {
messagesThread.lastMessage = message;
}
//////////////////////////////////////////////////////EDIT/////////////////////////////////////////////////////////
This is the function responsible for adding a new message:
addNewMessage(objMessage: any) : void {
const flo: User = new User(objMessage.author, objMessage.site);
const newThread: Thread = new Thread(objMessage.id, [flo]);
const newMessage = new Message(objMessage);
objMessage.date = moment().toDate();
newThread.messages = Observable.of([newMessage]);
newThread.messages.last().subscribe((message) => {
newThread.lastMessage = message;
}); //DOESN'T WORK
objMessage.thread = newThread;
this.addMessage(newMessage);
this.addThread(newThread);
}
The initializations of my variables are done like so:
messages: Observable<Message[]>;
lastMessage: Message = null;
An error that I encounter is:
Type 'Message[]' is not assignable to type 'Message'