¿Qué es lo útil para "Suscribirse proporcionando asunto" y qué significa esto:- 1- por qué uso suscribir proporcionando asunto
import { Subject, from } from 'rxjs'; const subject = new Subject<number>(); subject.subscribe({ next: (v) => console.log(`observerA: ${v}`) }); subject.subscribe({ next: (v) => console.log(`observerB: ${v}`) }); const observable = from([1, 2, 3]); observable.subscribe(subject); // You can subscribe providing a Subject // Logs: // observerA: 1 // observerB: 1 // observerA: 2 // observerB: 2 // observerA: 3 // observerB: 3Se suscribe a un Observable RxJS con un Observador. Esta es la interfaz mecanografiada para un observador.
interface Observer<T> { closed?: boolean; next: (value: T) => void; error: (err: any) => void; complete: () => void; } o un observador parcial (solo implemente algunas de las devoluciones de llamada) o con una función (que es lo mismo que un observador parcial con solo la next devolución de llamada).
¡Resulta que un sujeto implementa la interfaz de observador y, por lo tanto, puede usarse como observador! Esta es una forma sencilla de multidifundir un observable (y cómo funcionan los operadores de multidifusión hasta cierto punto).