Estoy aprendiendo Asunto de RXJS y no entiendo por qué en esta situación la función next() no envía la información:
import {Subject, from} from 'rxjs'; const subject = new Subject<any>(); 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); subject.next(4) // not workingSi actualiza con complete , verá que se completa automáticamente cuando pasa directamente subject a suscribirse.
subject.subscribe({ next: (v) => console.log(`observerA: ${v}`), error: (error) => console.log(error), complete: () => console.log('completed') });