# publishLast

💡 publishLast es equivalente a `multicast(() => new AsyncSubject())`

<details>

<summary>Signatura</summary>

#### Firma

`publishLast<T>(): UnaryFunction<Observable<T>, ConnectableObservable<T>>`

#### Parámetros

No recibe ningún parámetro.

### Retorna

`UnaryFunction<Observable<T>, ConnectableObservable<T>>`: Una secuencia observable que contiene los elementos de una secuencia producida al multidifundir la secuencia fuente.

</details>

## 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 [multicast](https://github.com/puntotech/rxjs-docu/blob/master/operators/multicasting/multicast/README.md) junto a un AsyncSubject internamente.

![Diagrama de canicas del operador publishLast](https://github.com/puntotech/rxjs-docu/blob/master/doc/operators/multicasting/assets/images/marble-diagrams/multicasting/publishLast.png)

Es similar a [publish](https://github.com/puntotech/rxjs-docu/blob/master/operators/multicasting/publish/README.md), pero espera a que el Observable fuente se complete, para almacenar su último valor emitido. Al igual que [publishReplay](https://github.com/puntotech/rxjs-docu/blob/master/operators/multicasting/publishReplay/README.md) y [publishBehavior](https://github.com/puntotech/rxjs-docu/blob/master/operators/multicasting/publishBehavior/README.md), 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**

[StackBlitz](https://stackblitz.com/edit/docu-rxjs-publishlast?file=index.html)

```typescript
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**

[StackBlitz](https://stackblitz.com/edit/docu-rxjs-publishlast-2?file=index.ts)

```javascript
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

```javascript
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"
```

### Recursos adicionales

[![Source code](https://github.com/puntotech/rxjs-docu/blob/master/doc/operators/multicasting/assets/icons/source-code.png)](https://github.com/ReactiveX/rxjs/blob/master/src/internal/operators/publishLast.ts)

[Documentación oficial en inglés](https://rxjs.dev/api/operators/publishLast)