how does cleanup work for observables.

[prabirshrestha]

I didn't see any unsubscribe or takeUtil in the MessageService. How does cleanup work?

If I create a new instance for MessageService for each test how would the old subscription clean up?

[alessioalex]

@prabirshrestha you might be on to something. As far as I've checked the async pipe automatically calls unsubscribe from an observable when the component is destroyed, however in the app there are multiple subscribe()-s happening without cleanup (not using async pipe, ngOnDestroy cleanup via unsubscribe() nor takeUntil).

[alessioalex]

@jashmenn can you take a look at this please and confirm/deny our suspicions?

[hsbalar]

@alessioalex @prabirshrestha Guys can you help me here, How do I cleanup messages stream. I want to clean all messages from messageService message observable.
I tried via unsubscribe but if I try to reuse that observable it gives me an error : ObjectUnsubscribedError {name: "ObjectUnsubscribedError", stack: "ObjectUnsubscribedError: object unsubscribed

[zahid49]

Hi , i'm using this app and facing problem with messages and threads .....
when we re_route to chat app it duplicates messages and threads ...
please help .. @alessioalex @prabirshrestha @hsbalar @auser

[hsbalar]

@zahid49 You can call following method to clear message stream

this.remove
  .map( function(): IMessagesOperation {
    return (messages: Message[]) => {
      return messages = [];
    };
  })
  .subscribe(this.updates);

  disposeMessages() {
    this.remove.next();
  }

Declare remove in class
remove: Subject = new Subject();

[zahid49]

Thanks... You are Awesome!

…

On Sep 6, 2017 5:37 PM, "Hitesh" ***@***.***> wrote: @zahid49 <https://github.com/zahid49> You can call following method to clear message stream this.remove .map( function(): IMessagesOperation { return (messages: Message[]) => { return messages = []; }; }) .subscribe(this.updates); disposeMessages() { this.remove.next(); } — You are receiving this because you were mentioned. Reply to this email directly, view it on GitHub <#16 (comment)>, or mute the thread <https://github.com/notifications/unsubscribe-auth/AeObDHJSAbNblZrBC7bjsAklXTAKN0q_ks5sfpHsgaJpZM4HX4O0> .

[zahid49]

hey , @hsbalar @prabirshrestha @alessioalex @auser @fcoury
how can i get newly message from other users without refrshing page ??

[zahid49]

Hi dear , can u please again help me out ... how can i get newly message from other users without refrshing page ?? On Wed, Sep 6, 2017 at 6:27 PM, Muhammad Zahid <mz.ansari49@gmail.com> wrote:

…

Thanks... You are Awesome! On Sep 6, 2017 5:37 PM, "Hitesh" ***@***.***> wrote: > @zahid49 <https://github.com/zahid49> You can call following method to > clear message stream > > this.remove > .map( function(): IMessagesOperation { > return (messages: Message[]) => { > return messages = []; > }; > }) > .subscribe(this.updates); > > disposeMessages() { > this.remove.next(); > } > > — > You are receiving this because you were mentioned. > Reply to this email directly, view it on GitHub > <#16 (comment)>, > or mute the thread > <https://github.com/notifications/unsubscribe-auth/AeObDHJSAbNblZrBC7bjsAklXTAKN0q_ks5sfpHsgaJpZM4HX4O0> > . >

[hsbalar]

hey sorry I was not able to reply you. which library you have used for chat. can you tell me how to getting messages

…

On 08-Sep-2017 3:54 PM, "zahid49" ***@***.***> wrote: Hi dear , can u please again help me out ... how can i get newly message from other users without refrshing page ?? On Wed, Sep 6, 2017 at 6:27 PM, Muhammad Zahid ***@***.***> wrote: > Thanks... You are Awesome! > > On Sep 6, 2017 5:37 PM, "Hitesh" ***@***.***> wrote: > >> @zahid49 <https://github.com/zahid49> You can call following method to >> clear message stream >> >> this.remove >> .map( function(): IMessagesOperation { >> return (messages: Message[]) => { >> return messages = []; >> }; >> }) >> .subscribe(this.updates); >> >> disposeMessages() { >> this.remove.next(); >> } >> >> — >> You are receiving this because you were mentioned. >> Reply to this email directly, view it on GitHub >> <#16# issuecomment-327469803>, >> or mute the thread >> <https://github.com/notifications/unsubscribe-auth/ AeObDHJSAbNblZrBC7bjsAklXTAKN0q_ks5sfpHsgaJpZM4HX4O0> >> . >> > — You are receiving this because you were mentioned. Reply to this email directly, view it on GitHub <#16 (comment)>, or mute the thread <https://github.com/notifications/unsubscribe-auth/APl5YDcZa-EeDJg5QNoMMlPH0jNwsbzKks5sgRXwgaJpZM4HX4O0> .

[zahid49]

actually i'm loading initial messages from database on init function... it is working fine ... but when send new message it is not get on other end without refreshing page ...

…

On Sat, Sep 9, 2017 at 5:51 PM, Hitesh ***@***.***> wrote: hey sorry I was not able to reply you. which library you have used for chat. can you tell me how to getting messages On 08-Sep-2017 3:54 PM, "zahid49" ***@***.***> wrote: > Hi dear , > can u please again help me out ... > how can i get newly message from other users without refrshing page ?? > > On Wed, Sep 6, 2017 at 6:27 PM, Muhammad Zahid ***@***.***> > wrote: > > > Thanks... You are Awesome! > > > > On Sep 6, 2017 5:37 PM, "Hitesh" ***@***.***> wrote: > > > >> @zahid49 <https://github.com/zahid49> You can call following method to > >> clear message stream > >> > >> this.remove > >> .map( function(): IMessagesOperation { > >> return (messages: Message[]) => { > >> return messages = []; > >> }; > >> }) > >> .subscribe(this.updates); > >> > >> disposeMessages() { > >> this.remove.next(); > >> } > >> > >> — > >> You are receiving this because you were mentioned. > >> Reply to this email directly, view it on GitHub > >> <#16# > issuecomment-327469803>, > >> or mute the thread > >> <https://github.com/notifications/unsubscribe-auth/ > AeObDHJSAbNblZrBC7bjsAklXTAKN0q_ks5sfpHsgaJpZM4HX4O0> > >> . > >> > > > > — > You are receiving this because you were mentioned. > Reply to this email directly, view it on GitHub > <#16# issuecomment-328067499>, > or mute the thread > <https://github.com/notifications/unsubscribe-auth/APl5YDcZa- EeDJg5QNoMMlPH0jNwsbzKks5sgRXwgaJpZM4HX4O0> > . > — You are receiving this because you were mentioned. Reply to this email directly, view it on GitHub <#16 (comment)>, or mute the thread <https://github.com/notifications/unsubscribe-auth/AeObDJftSGY9jqI3QkVXWIvQv22mpSMsks5sgonggaJpZM4HX4O0> .

[hsbalar]

Do you use any webSocket or anything that connects your frontend with backend

…

On Mon, Sep 11, 2017 at 2:48 PM, zahid49 ***@***.***> wrote: actually i'm loading initial messages from database on init function... it is working fine ... but when send new message it is not get on other end without refreshing page ... On Sat, Sep 9, 2017 at 5:51 PM, Hitesh ***@***.***> wrote: > hey sorry I was not able to reply you. > which library you have used for chat. > can you tell me how to getting messages > > On 08-Sep-2017 3:54 PM, "zahid49" ***@***.***> wrote: > > > Hi dear , > > can u please again help me out ... > > how can i get newly message from other users without refrshing page ?? > > > > On Wed, Sep 6, 2017 at 6:27 PM, Muhammad Zahid ***@***.***> > > wrote: > > > > > Thanks... You are Awesome! > > > > > > On Sep 6, 2017 5:37 PM, "Hitesh" ***@***.***> wrote: > > > > > >> @zahid49 <https://github.com/zahid49> You can call following method > to > > >> clear message stream > > >> > > >> this.remove > > >> .map( function(): IMessagesOperation { > > >> return (messages: Message[]) => { > > >> return messages = []; > > >> }; > > >> }) > > >> .subscribe(this.updates); > > >> > > >> disposeMessages() { > > >> this.remove.next(); > > >> } > > >> > > >> — > > >> You are receiving this because you were mentioned. > > >> Reply to this email directly, view it on GitHub > > >> <#16# > > issuecomment-327469803>, > > >> or mute the thread > > >> <https://github.com/notifications/unsubscribe-auth/ > > AeObDHJSAbNblZrBC7bjsAklXTAKN0q_ks5sfpHsgaJpZM4HX4O0> > > >> . > > >> > > > > > > > — > > You are receiving this because you were mentioned. > > Reply to this email directly, view it on GitHub > > <#16# > issuecomment-328067499>, > > or mute the thread > > <https://github.com/notifications/unsubscribe-auth/APl5YDcZa- > EeDJg5QNoMMlPH0jNwsbzKks5sgRXwgaJpZM4HX4O0> > > . > > > > > — > You are receiving this because you were mentioned. > Reply to this email directly, view it on GitHub > <#16# issuecomment-328275433>, > or mute the thread > <https://github.com/notifications/unsubscribe-auth/ AeObDJftSGY9jqI3QkVXWIvQv22mpSMsks5sgonggaJpZM4HX4O0> > . > — You are receiving this because you were mentioned. Reply to this email directly, view it on GitHub <#16 (comment)>, or mute the thread <https://github.com/notifications/unsubscribe-auth/APl5YL4x3LZZN8XO4vrVU2qRN4DLvE4Cks5shPrKgaJpZM4HX4O0> .

[zahid49]

@hsbalar @alessioalex , i'm still on how to get recent message on other user end ... can u please help out .

[zahid49]

@hsbalar @auser @fcoury @alessioalex @prabirshrestha
How can i Clear All Threads from app.