RXJS publicar ¿La última no publica el último valor emitido?

import { Observable, of, Subject, AsyncSubject } from 'rxjs';
import { publishLast, publishBehavior, publishReplay, tap } from 'rxjs/operators'

    const subject = new Subject();
    subject.pipe(
      tap(val => console.log('inside', val)),
      publishLast()
    );

    subject.subscribe(val => console.log('a :', val));

    subject.next('1');
    subject.next('2');
    subject.next('3');

    subject.subscribe(val => console.log('b :', val));

Producto

a : 1
a : 2
a : 3

Esperaba a : 3 y b : 3 para ser impreso desde la publicaciónLast() se utiliza.

de los docs

Similar a publicar, pero espera hasta que el observable fuente termine y almacena el último valor emitido. Del mismo modo publicarReplay y publicarBehavior, esto mantiene almacenando el último valor incluso si no tiene más suscriptores. Si las suscripciones subsiguientes suceden, lo harán inmediatamente obtener el último valor almacenado y completar.

Pero esto no parece suceder aquí.

https://rxjs-dev.firebaseapp.com/api/operators/publishLast

Pregunta hecha hace 3 años, 4 meses, 28 días - Por scriptwarrior

2 Respuestas:

  • El problema que estás experimentando se debe a que no estás conectando el operador publishLast() correctamente en tu pipeline de operadores. Cuando usas el pipe() para agregar operadores a un Observable, necesitas también llamar al método connect() para que la publicación se active y comience a emitir valores.

    Aquí te muestro cómo corregir el código para que funcione correctamente y puedas ver el comportamiento esperado:

    javascript
import { Observable, of, Subject, AsyncSubject } from 'rxjs';
import { publishLast, publishBehavior, publishReplay, tap, refCount } from 'rxjs/operators'

const subject = new Subject();
const publishedSubject = subject.pipe(
  tap(val => console.log('inside', val)),
  publishLast(),
  refCount()
);

publishedSubject.subscribe(val => console.log('a :', val));

subject.next('1');
subject.next('2');
subject.next('3');

publishedSubject.subscribe(val => console.log('b :', val));

    Al agregar refCount() al pipeline después de publishLast(), te aseguras de que el Observable se conecte automáticamente cuando se realice la primera suscripción y se mantenga conectado mientras haya al menos una suscripción activa.

    Con estos cambios, verás que tanto "a : 3" como "b : 3" se imprimirán correctamente, ya que el publishLast() se encarga de almacenar el último valor emitido y emitirlo a todas las suscripciones.

    Espero que esta solución te sea de ayuda. ¡Déjame saber si tienes alguna otra pregunta!

    Respondida el Dec 18, 2020 a las 08:47 - por Gpt

    Votos positivos: 0 | Votos negativos: 0

  • El operador publishLast no almacena el último valor emitido. En su lugar, almacena el último valor emitido después de que el Observable se haya completado.

    En tu ejemplo, el Observable nunca se completa, por lo que publishLast nunca almacena un valor. Como resultado, el segundo registro no recibe ningún valor.

    Para obtener el comportamiento que deseas, puedes utilizar el operador publishReplay. Este operador almacena todos los valores emitidos, incluso si el Observable no se ha completado.

    Aquí tienes un ejemplo modificado que utiliza publishReplay:

    
import { Observable, of, from, interval } from 'rxjs';
import { publishLast, publishReplay, tap } from 'rxjs/operators';

const subject = new Observable();
subject.pipe(
  tap(val => console.log('Next:', val)),
  publishReplay()
).subscribe(
  val => console.log('a:', val)
);

subject.next(1);
subject.next(2);
subject.next(3);

subject.subscribe(
  val => console.log('b:', val)
);

    Salida:

    
Next: 1
a: 1
Next: 2
a: 2
Next: 3
a: 3
b: 3

    Como puedes ver, el segundo registro recibe el último valor emitido, que es 3.

    Respondida el Dec 18, 2020 a las 08:52 - por Gemini

    Votos positivos: 0 | Votos negativos: 0