Czy powinienem zrezygnować z usługi Cold Observable?

Question

Wiem, że to dobra praktyka, aby anulować subskrypcję z Observable, aby zapobiec wyciekowi pamięci .

Ale jeśli jest to Cold Observable, czy powinienem również zrezygnować z subskrypcji?

na przykład jeden, który jest zwracany przez Http.get()

Answer 1

nie musisz tego robić, ponieważ HTTP obserwowalne dzwoni pełna jest natychmiast po akcja jest wykonywana.

Z kodu źródłowego sources Widzę, że po wypisaniu się jest wywoływany przy błędzie i po zakończeniu.

protected _error(err: any): void { 
    this.destination.error(err); 
    this.unsubscribe(); 
    } 

    protected _complete(): void { 
    this.destination.complete(); 
    this.unsubscribe(); 
    } 

poszedłem dalej i zrobił mały eksperyment dodając wypisać z limitu czasu

var subscription = this.http.get(`apiurl`) 
      .subscribe(response => { 
       setTimeout(function(){ 
        debugger; 
        subscription.unsubscribe(); }, 30); 
      }); 

gdybym kroku wewnątrz unsibscribe do

Subscriber.prototype.unsubscribe = function() { 
     if (this.closed) { // this.closed is true 
      return; 
     } 
     this.isStopped = true; 
     _super.prototype.unsubscribe.call(this); 
    }; 

Następnie this.closed == true, czyli wypisz nazwano wcześniej.

Więc tak teraz mogę powiedzieć na pewno nie trzeba zrezygnować :)

Answer 2

Jest to zdecydowanie najlepsza praktyka uwolnić zajętej pamięci w javascript podobnie jak innych języków programowania.

Ponieważ używasz kątowego 2, możesz użyć haka cyklu życia, aby uzyskać tę metodę, gdy komponent traci zasięg.

Zakładając, że używasz poniżej fragment zapisać się do danych

subscription = this._http.getMethod('...') 
        .subscribe(response => this.responses = response, 
        error =>this.errorMessage =<any> error) 

należy używać importowania hak cyklem OnDestroy z kątowym/rdzenia przy użyciu instrukcji import.

import { OnDestroy } from '@angular/core' 

wdrożyć OnDestroy w składniku jak

export class MyComponent implements onDestroy { 
    ............. 


    ngOnDestroy() { 
      this.subscription.unsubscribe(); 
    } 

}