0

soy nuevo en Angular y estoy tratando de concatenar dos observables uno de ellos viene de un servicio API Rest, y no puedo obtener la salida que espero, solo obtengo dos renglones. Desde ya gracias.

el que viene del servicio rest es:

[
{"prueba_id":1,"distancia":"100"},
{"prueba_id":2,"distancia":"200"},
{"prueba_id":3,"distancia":"400"},
....
]

const sexo$ = from([{sexo: 'Masculino'}, {sexo: 'Femenino'}]);

La salida que espero

[
{"prueba_id":1,"distancia":"100","sexo": "Masculino"},
{"prueba_id":1,"distancia":"100","sexo": "Femenino"},
{"prueba_id":2,"distancia":"200","sexo": "Masculino"},
{"prueba_id":2,"distancia":"200","sexo": "Femenino"},
{"prueba_id":3,"distancia":"400","sexo": "Masculino"},
{"prueba_id":3,"distancia":"400","sexo": "Femenino"},
....
]

this.pruebaService.getPruebas().pipe(
  concatMap( (prueba: Prueba[]) => 
    sexo$.pipe(map( (sexo,i) => { return {...prueba[i], sexo: sexo.sexo}})
    )
  )
).subscribe( (rta) => { 
  console.log('JSON.stringify(rta))
},
  error => console.log("Error: " + error),
  () => console.log("Ok: ")
)
2
  • Tienes un atributo comun entre la llamada que devuelve las pruebas y la de los sexos o lo que quieres es generar una entrada duplicada para que por cada prueba haya dos entradas una para cada sexo?
    – Narshe
    el 23 oct. 2019 a las 19:34
  • Tal cual, lo que quiero es generar dos entradas para la misma prueba una por cada sexo. el 24 oct. 2019 a las 20:31

1 respuesta 1

1

Con flatMap

of([
    { "prueba_id": 1, "distancia": "100" },
    { "prueba_id": 2, "distancia": "200" },
    { "prueba_id": 3, "distancia": "400" }
])
    .pipe(
        switchMap(pruebas =>
            of([{ sexo: 'Masculino' }, { sexo: 'Femenino' }])
                .pipe(
                    map(sexos =>
                        pruebas.flatMap(prueba =>
                            sexos.map(({ sexo }) =>
                                ({
                                    ...prueba,
                                    sexo
                                })
                            )
                        )
                    )
                )
        )
    )

Con flat

of([
    { "prueba_id": 1, "distancia": "100" },
    { "prueba_id": 2, "distancia": "200" },
    { "prueba_id": 3, "distancia": "400" }
])
    .pipe(
        switchMap(pruebas =>
            of([{ sexo: 'Masculino' }, { sexo: 'Femenino' }])
                .pipe(
                    map(sexos =>
                        pruebas
                            .map(prueba =>
                                sexos.map(({ sexo }) =>
                                    ({
                                        ...prueba,
                                        sexo
                                    })
                                )
                            )
                            .flat()
                    )
                )
        )
    )

Si la ejecución del segundo Observable no depende de que la ejecución del primero haya terminado, es decir si después de la ejecución del primer Observable no se espera un parámetro necesario para hacer la consulta del segundo, puedes hacer lo siguiente

combineLatest(
    of([
        { "prueba_id": 1, "distancia": "100" },
        { "prueba_id": 2, "distancia": "200" },
        { "prueba_id": 3, "distancia": "400" }
    ]),
    of([{ sexo: 'Masculino' }, { sexo: 'Femenino' }])
)

    .pipe(
        map(([pruebas, sexos]) =>
            pruebas.flatMap(prueba =>
                sexos.map(({ sexo }) =>
                    ({
                        ...prueba,
                        sexo
                    })
                )
            )
        )
    )

Tu Respuesta

By clicking “Publica tu respuesta”, you agree to our terms of service and acknowledge you have read our privacy policy.

¿No es la respuesta que buscas? Examina otras preguntas con la etiqueta o formula tu propia pregunta.