File tree Expand file tree Collapse file tree 1 file changed +15
-12
lines changed
projects/stream-chat-angular/src/lib Expand file tree Collapse file tree 1 file changed +15
-12
lines changed Original file line number Diff line number Diff line change @@ -401,18 +401,21 @@ export class ChannelService {
401401 }
402402
403403 private messageReactionEventReceived ( e : Event ) {
404- let messages ! : StreamMessage [ ] ;
405- this . activeChannelMessages$ . pipe ( first ( ) ) . subscribe ( ( m ) => ( messages = m ) ) ;
406- const message = messages . find ( ( m ) => m . id === e ?. message ?. id ) ;
407- if ( ! message ) {
408- return ;
409- }
410- message . reaction_counts = { ...e . message ?. reaction_counts } ;
411- message . reaction_scores = { ...e . message ?. reaction_scores } ;
412- message . latest_reactions = [ ...( e . message ?. latest_reactions || [ ] ) ] ;
413- message . own_reactions = [ ...( e . message ?. own_reactions || [ ] ) ] ;
414- this . activeChannelMessagesSubject . next ( [ ...messages ] ) ;
415- this . appRef . tick ( ) ;
404+ this . ngZone . run ( ( ) => {
405+ let messages ! : StreamMessage [ ] ;
406+ this . activeChannelMessages$
407+ . pipe ( first ( ) )
408+ . subscribe ( ( m ) => ( messages = m ) ) ;
409+ const message = messages . find ( ( m ) => m . id === e ?. message ?. id ) ;
410+ if ( ! message ) {
411+ return ;
412+ }
413+ message . reaction_counts = { ...e . message ?. reaction_counts } ;
414+ message . reaction_scores = { ...e . message ?. reaction_scores } ;
415+ message . latest_reactions = [ ...( e . message ?. latest_reactions || [ ] ) ] ;
416+ message . own_reactions = [ ...( e . message ?. own_reactions || [ ] ) ] ;
417+ this . activeChannelMessagesSubject . next ( [ ...messages ] ) ;
418+ } ) ;
416419 }
417420
418421 private formatMessage ( message : MessageResponse ) {
You can’t perform that action at this time.
0 commit comments