Temat vs zachowanie Temat vs Powtórka Temat w Angular

Chciałem zrozumieć te 3:

Temat , temat zachowania i temat powtórki . Chciałbym ich używać i wiedzieć, kiedy i dlaczego, jakie są korzyści z ich używania i chociaż przeczytałem dokumentację, obejrzałem tutoriale i przeszukałem google, nie udało mi się tego zrozumieć.

Więc jaki jest ich cel? Najbardziej ceniona byłaby rzeczywista obudowa, która nie musi nawet kodować.

Wolałbym jasne wyjaśnienie, a nie tylko „a + b => c jesteś subskrybentem ....”

Dziękuję Ci

To naprawdę sprowadza się do zachowania i semantyki. Z

• Subject- subskrybent otrzyma tylko opublikowane wartości, które zostały wyemitowane po subskrypcji. Zadaj sobie pytanie, czy tego chcesz? Czy subskrybent musi wiedzieć cokolwiek o poprzednich wartościach? Jeśli nie, możesz tego użyć, w przeciwnym razie wybierz jedną z pozostałych. Na przykład z komunikacją między komponentami. Załóżmy, że masz komponent, który publikuje zdarzenia dla innych komponentów po kliknięciu przycisku. Możesz skorzystać z usługi z tematem do komunikacji.

• BehaviorSubject- ostatnia wartość jest buforowana. Abonent otrzyma najnowszą wartość przy pierwszej subskrypcji. Semantyka tego przedmiotu polega na przedstawieniu wartości, która zmienia się w czasie. Na przykład zalogowany użytkownik. Początkowy użytkownik może być użytkownikiem anonimowym. Ale gdy użytkownik się zaloguje, nową wartością jest stan uwierzytelnionego użytkownika.

  BehaviorSubjectInicjowany jest z wartością początkową. Czasami jest to ważne dla preferencji kodowania. Powiedz na przykład, że inicjalizujesz go za pomocą pliku null. Następnie w swojej subskrypcji musisz sprawdzić zerową wartość. Może OK, a może denerwujące.

• ReplaySubject- może buforować do określonej liczby emisji. Wszyscy subskrybenci otrzymają wszystkie wartości zapisane w pamięci podręcznej po subskrypcji. Kiedy potrzebujesz takiego zachowania? Szczerze mówiąc, nie miałem potrzeby takiego zachowania, z wyjątkiem następującego przypadku:

  Jeśli zainicjujesz a ReplaySubjectz rozmiarem bufora 1, to w rzeczywistości zachowuje się tak jak a BehaviorSubject. Ostatnia wartość jest zawsze buforowana, więc zachowuje się jak wartość zmieniająca się w czasie. Dzięki temu nie ma potrzeby nullsprawdzania, jak w przypadku BehaviorSubjectinicjalizacji z rozszerzeniem null. W tym przypadku żadna wartość nie jest wysyłana do subskrybenta aż do pierwszej publikacji.

Tak więc naprawdę sprowadza się to do zachowania, którego oczekujesz (od tego, którego użyć). W większości przypadków prawdopodobnie będziesz chciał użyć a, BehaviorSubjectponieważ to, co naprawdę chcesz reprezentować, to semantyczna „wartość w czasie”. Ale ja osobiście nie widzę nic złego w zamianie ReplaySubjectinicjalizacji na 1.

To, czego chcesz uniknąć, to używanie wanilii, Subjectgdy naprawdę potrzebujesz zachowania pamięci podręcznej. Weźmy na przykład piszesz strażnika uciekającego lub rozwiązanie. Pobierasz dane z tej warty i ustawiasz je w usłudze Subject. Następnie w komponencie kierowanym subskrybujesz temat usługi, aby spróbować uzyskać wartość, która została wyemitowana w strażniku. OOP. Gdzie jest wartość? To już było wyemitowane, DUH. Użyj tematu "buforowania"!

Zobacz też:

• Jakie są tematy RxJS i korzyści z ich używania?

Poręczne podsumowanie różnych obserwowalnych typów, nieintuicyjne nazewnictwo, które znam lol .

• Subject - Abonent otrzyma opublikowane wartości dopiero po dokonaniu subskrypcji.
• BehaviorSubject - Nowi subskrybenci otrzymują ostatnią opublikowaną wartość LUB wartość początkową natychmiast po subskrypcji.
• ReplaySubject - Nowi subskrybenci otrzymują wszystkie wcześniej opublikowane wartości natychmiast po subskrypcji

1. Temat : Podczas subskrybowania zawsze pobiera dane, które są wysyłane po subskrypcji, tj. Poprzednie przekazane wartości nie są odbierane .

const mySubject = new Rx.Subject();

mySubject.next(1);

const subscription1 = mySubject.subscribe(x => {
  console.log('From subscription 1:', x);
});

mySubject.next(2);

const subscription2 = mySubject.subscribe(x => {
  console.log('From subscription 2:', x);
});

mySubject.next(3);

subscription1.unsubscribe();

mySubject.next(4);

W tym przykładzie, oto wynik, który zostanie wydrukowany w konsoli:

From subscription 1: 2
From subscription 1: 3
From subscription 2: 3
From subscription 2: 4

Zwróć uwagę, że subskrypcje, które przychodzą późno, nie obejmują niektórych danych, które zostały przesłane do tematu.

2. Powtórz tematy : może pomóc, zachowując bufor poprzednich wartości, które zostaną wyemitowane do nowych subskrypcji.

Oto przykład użycia tematów powtórek, w których buffer of 2 previous valuessą przechowywane i emitowane przy nowych subskrypcjach:

const mySubject = new Rx.ReplaySubject(2);

mySubject.next(1);
mySubject.next(2);
mySubject.next(3);
mySubject.next(4);

mySubject.subscribe(x => {
  console.log('From 1st sub:', x);
});

mySubject.next(5);

mySubject.subscribe(x => {
  console.log('From 2nd sub:', x);
});

Oto, co daje nam to na konsoli:

From 1st sub: 3
From 1st sub: 4
From 1st sub: 5
From 2nd sub: 4
From 2nd sub: 5

3. Tematy dotyczące zachowania : są podobne do tematów powtórek, ale ponownie wyemitują tylko ostatnią emitowaną wartość lub wartość domyślną, jeśli żadna wartość nie została wcześniej wyemitowana:

const mySubject = new Rx.BehaviorSubject('Hey now!');

mySubject.subscribe(x => {
  console.log('From 1st sub:', x);
});

mySubject.next(5);

mySubject.subscribe(x => {
  console.log('From 2nd sub:', x);
});

A wynik:

From 1st sub: Hey now!
From 1st sub: 5
From 2nd sub: 5

Źródła: https://alligator.io/rxjs/subjects/

Od: Randall Koutnik książka „Build Reactive Websites with RxJS”. :

Temat jest obiektem, który jest turbodoładowany obserwowalne. W swej istocie, Temat działa podobnie jak zwykły obserwowalne, ale każda subskrypcja jest podpięty do tego samego źródła. Podmioty są również obserwatorami i mają następne, błędne i wykonane metody, aby przesłać dane do wszystkich subskrybentów jednocześnie. Ponieważ podmioty są obserwatorami, mogą zostać przekazane bezpośrednio do wywołania subskrypcji, a wszystkie zdarzenia z pierwotnego obserwowalnego zostaną przesłane przez podmiot do jego subskrybentów.

Możemy użyć ReplaySubject do śledzenia historii. ReplaySubject rejestruje ostatnie wydarzenia N i Pałys je z powrotem do każdego nowego abonenta. Na przykład w aplikacji do czatu. Możemy go użyć do śledzenia historii poprzednich czatów.

BehaviorSubject jest uproszczona wersja ReplaySubject . Obiekt ReplaySubject przechowuje dowolną liczbę zdarzeń, a BehaviorSubject rejestruje tylko wartość ostatniego zdarzenia. Za każdym razem, gdy BehaviorSubject rejestruje nową subskrypcję, emituje najnowszą wartość do subskrybenta, a także wszelkie nowe wartości, które są przekazywane. The BehaviorSubject jest przydatny w przypadku pojedynczych jednostek stanu, takich jak opcje konfiguracji.

Najbardziej pozytywna odpowiedź jest po prostu błędna, twierdząc, że:

„Jeśli zainicjujesz a ReplaySubjectz rozmiarem bufora 1, to w rzeczywistości zachowuje się jak a BehaviorSubject”

To nie jest do końca prawdą; sprawdź ten wspaniały wpis na blogu dotyczący różnic między nimi. Na przykład, jeśli zasubskrybujesz ukończone BehaviorSubject, nie otrzymasz ostatniej wartości, ale za a ReplaySubject(1)otrzymasz ostatnią wartość.

To jest ważna różnica, której nie należy przeoczyć:

const behavior = new BehaviorSubject(null);
const replay = new ReplaySubject(1);

behavior.skip(1).subscribe(v => console.log('BehaviorSubject:', v));
replay.subscribe(v => console.log('ReplaySubject:', v));

behavior.next(1);
behavior.next(2);
behavior.complete();
behavior.subscribe(v => console.log('Late B subscriber:', v));

replay.next(1);
replay.next(2);
replay.complete();
replay.subscribe(v => console.log('Late R subscriber:', v));

Sprawdź ten przykład kodu , który pochodzi z innego świetnego wpisu na blogu na ten temat.

     // ***********Subject  concept ***********
    let subject = new Subject<string>();


    subject.next("Eureka");
    subject.subscribe((data) => {
      console.log("Subscriber 1 got data >>>>> "+ data);
    });
    subject.subscribe((data) => {
      console.log("Subscriber 2 got data >>>>> "+ data);
    });

       // ********behaviour subject*********
    // Behavior subjects need a first value
let subject1 = new BehaviorSubject<string>("First value");


subject1.asObservable().subscribe((data) => {
  console.log("First subscriber got data behaviour subject>>>>> "+ data);
});
subject1.next("Second value")

• Temat - subskrybent otrzyma opublikowane w nim wartości dopiero po dokonaniu subskrypcji.
• BehaviorSubject - Nowi subskrybenci otrzymują ostatnią opublikowaną wartość LUB wartość początkową natychmiast po subskrypcji.