Scribd
Cargar
9 vistas1 página

Contar y procesar números en RxJava

Este documento contiene dos pruebas unitarias que utilizan RxJava para procesar listas de números enteros. La primera prueba cuenta el número de elementos mayores a 10 en una lista usando streams. La segunda prueba aplica operaciones como mapeo, filtrado y suscripción a una lista usando RxJava, para obtener los cuadrados de los números que son pares. También define una función para calcular cuadrados y un método observable que encapsula las operaciones de procesamiento de lista.

Cargado por

Cesar David Guerrero Hidalgo
Derechos de autor
© All Rights Reserved
Nos tomamos en serio los derechos de los contenidos. Si sospechas que se trata de tu contenido, reclámalo aquí.
Formatos disponibles
Descarga como TXT, PDF, TXT o lee en línea desde Scribd
9 vistas1 página

Contar y procesar números en RxJava

Este documento contiene dos pruebas unitarias que utilizan RxJava para procesar listas de números enteros. La primera prueba cuenta el número de elementos mayores a 10 en una lista usando streams. La segunda prueba aplica operaciones como mapeo, filtrado y suscripción a una lista usando RxJava, para obtener los cuadrados de los números que son pares. También define una función para calcular cuadrados y un método observable que encapsula las operaciones de procesamiento de lista.

Cargado por

Cesar David Guerrero Hidalgo
Derechos de autor
© All Rights Reserved
Nos tomamos en serio los derechos de los contenidos. Si sospechas que se trata de tu contenido, reclámalo aquí.
Formatos disponibles
Descarga como TXT, PDF, TXT o lee en línea desde Scribd

@Test

public void testRxjava() {


List<Integer> numeros = new ArrayList<Integer>();
[Link](2);
[Link](34);
[Link](7);
[Link](15);

Long result = [Link]().filter(n -> n > 10).count();


[Link]("total de registros mayores a 10: " + result);

@Test
public void testRxjava2() {
List<Integer> numeros = new ArrayList<Integer>();
[Link](7);
[Link](78);
[Link](100);
[Link](33);
[Link](25);
[Link](11);
[Link](2);

[Link](numeros) // encapsular
.flatMapIterable(x -> x) // emito elemento por elemento
.map(x -> [Link](x)) // transformar
.filter(cuadrado -> cuadrado % 2 == 0) // filtrar aplicando una logica
.subscribe([Link]::println); // subscribirme y presentar

Function<Integer, Integer> cuadradoDeNumero = x -> {


return x * x;
};

Observable<Integer> procesamientoLista(List<Integer> numeros) {

return [Link](numeros) // encapsular


.flatMapIterable(x -> x) // emito elemento por elemento
.map(x -> [Link](x)) // transformar
.filter(cuadrado -> cuadrado % 2 == 0); // filtrar aplicando una logica

También podría gustarte