partition

Divide el Observable fuente en dos, uno con los valores que cumplen una condición, y otro con los valores que no la cumplan

Signatura

Firma

partition<T>(source: any, predicate: (value: T, index: number) => boolean, thisArg?: any): [Observable<T>, Observable<T>]

Parámetros

Retorna

[Observable<T>, Observable<T>]: Un array con dos Observables: uno con valores que cumplen la función predicate, y otro con valores que no la cumplen.

Descripción

Es como filter, pero retorna dos Observables: uno como el Observable resultante de filter, y otro con los valores que no han superado la condición.

partition retorna un array con dos Observables que dividen los valores del Observable fuente según cumplan o no la condición especificada por la función predicate. El primer Observable del array emite los valores que sí cumplen la condición (la función devuelva true.) El segundo Observable emite los valores que no cumplan la condición (la función devuelva false.) El primer Observable se comporta como el operador filter y el segundo como el operador filter con la condición negada.

Ejemplos

Dividir una serie de pogramadores en dos Observables, uno con los que sean de Frontend y otro con los restantes

StackBlitz

import { partition, from } from "rxjs";

const programmer$ = from([
  { name: "Juan", type: "Backend" },
  { name: "Toni", type: "Frontend" },
  { name: "Nya", type: "Backend" },
  { name: "Carlos", type: "Full stack" },
]);

const [frontendProgrammer$, miscellaneousProgrammer$] = partition(
  programmer$,
  ({ type }) => type === "Frontend"
);

// Emite los programadores frontend
frontendProgrammer$.subscribe(console.log);
// Salida: { name: "Toni", type: "Frontend" }

// Emite el resto de programadores
miscellaneousProgrammer$.subscribe(console.log);
/* Salida: 
{ name: "Juan", type: "Backend" },
{ name: "Nya", type: "Backend" },
{ name: "Carlos", type: "Full stack" }
*/

Dividir las peticiones realizadas con éxito y las peticiones fallidas en dos Observables distintos

StackBlitz

import { catchError, concatMap, map } from "rxjs/operators";
import { ajax } from "rxjs/ajax";
import { of, partition } from "rxjs";

const filmId$ = of(
  "58611129-2dbc-4a81-a72f-77ddfc1b1b49",
  "voy-a-provocar-un-404",
  "2baf70d1-42bb-4437-b551-e5fed5a87abe"
).pipe(
  concatMap((id) => getGhibliFilms(id)),
  catchError((err) => of(err))
);

function getGhibliFilms(id: string) {
  return ajax(`https://ghibliapi.herokuapp.com/films/${id}`);
}

const [successfulRequest$, failedRequest$] = partition(
  filmId$,
  ({ status }) => status === 200
);

successfulRequest$.pipe(map(({ response }) => response)).subscribe(console.log);
// Salida: { title: "Castle in the Sky"... }, { title: "My Neighbor Totoro"... }

failedRequest$.subscribe(console.log);
// Salida: Error { message: "ajax error 404"... }

Ejemplo de la documentación oficial

Divide una secuencia de números en dos Observables de números pares e impares

import { of, partition } from "rxjs";

const observableValues = of(1, 2, 3, 4, 5, 6);
const [evens$, odds$] = partition(
  observableValues,
  (value, index) => value % 2 === 0
);

odds$.subscribe((x) => console.log("impares", x));
evens$.subscribe((x) => console.log("pares", x));

// Salida:
// impares 1
// impares 3
// impares 5
// pares 2
// pares 4
// pares 6

Recursos adicionales

Documentación oficial en inglés