UnaryFunction<Observable<T>, ConnectableObservable<T>>: Una secuencia observable que contiene los elementos de una secuencia producida al multidifundir la secuencia fuente.
Descripción
Retorna una secuencia Observable conectable que comparte una sola suscripción a la secuencia subyacente, que contiene solo la última notificación. Para ello utiliza el operador junto a un AsyncSubject internamente.
Es similar a , pero espera a que el Observable fuente se complete, para almacenar su último valor emitido. Al igual que y , almacena este último valor emitido aunque no tenga ningún suscriptor. Si llega un suscriptor nuevo, este recibirá el valor almacenado y se completará.
Ejemplos
Compartir el Observable fuente, emitiendo únicamente su último valor
import { ConnectableObservable, interval, timer } from "rxjs";
import { publishLast, tap, take } from "rxjs/operators";
// number$ no empezará a emitir valores hasta que se haga una llamada a connect
const number$ = interval(1000).pipe(take(4));
const multicasted$ = number$.pipe(publishLast()) as ConnectableObservable<
number
>;
// Llamando a connect
multicasted$.connect();
multicasted$.subscribe((val) => console.log(`Observador 1: ${val}`));
multicasted$.subscribe((val) => console.log(`Observador 2: ${val}`));
/* Salida:
(4s)
Observador 1: 3,
Observador 2: 3
*/
Si el Observable fuente no llega a completarse, nunca se emitirá ningún valor
import { ConnectableObservable, interval } from "rxjs";
import { publishLast } from "rxjs/operators";
// El Observable fuente nunca se completa
const number$ = interval(1000);
const multicasted$ = number$.pipe(publishLast()) as ConnectableObservable<
number
>;
// Llamando a connect
multicasted$.connect();
multicasted$.subscribe(val => console.log(`Observador 1: ${val}`));
multicasted$.subscribe(val => console.log(`Observador 2: ${val}`));
// Salida:
Ejemplo de la documentación oficial
import { interval } from "rxjs";
import { publishLast, tap, take } from "rxjs/operators";
const connectable = interval(1000).pipe(
tap((x) => console.log("side effect", x)),
take(3),
publishLast()
);
connectable.subscribe(
(x) => console.log("Sub. A", x),
(err) => console.log("Sub. A Error", err),
() => console.log("Sub. A Complete")
);
connectable.subscribe(
(x) => console.log("Sub. B", x),
(err) => console.log("Sub. B Error", err),
() => console.log("Sub. B Complete")
);
connectable.connect();
// Salida:
// "side effect 0"
// "side effect 1"
// "side effect 2"
// "Sub. A 2"
// "Sub. B 2"
// "Sub. A Complete"
// "Sub. B Complete"
