Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Soy muy nuevo en la programación reactiva. Estoy consumiendo una API de webflux que devuelve una respuesta de flujo (application/stream+json). Mi tarea es llamar a la API y convertir la respuesta en una Lista. Aquí está mi parte de código para llamar a la API: ClientResponse res = webClient.method(HttpMethod.GET) .uri(“uri”) . . . Read more
Supongamos que tengo dos fuentes de eventos históricos, y que los eventos de cada fuente están ordenados cronológicamente. ¿Cómo puedo fusionar estas fuentes utilizando Reactor para que los eventos en el Flujo fusionado se emitan en orden cronológico? En RxNET, se puede utilizar una combinación de Observable.Generate() y HistoricalScheduler para . . . Read more
Estoy tratando de averiguar cómo llamar a un punto final que acepta un parámetro @Body de Flowable<Integer>, para suscribirse y procesar el flujo entrante (usando Micronaut y el marco RxJava). Tengo este controlador en Micronaut: @Post(uri = “inner”) @ExecuteOn(TaskExecutors.IO) HttpResponse inner(@Body Flowable<Integer> template){ template.subscribe(new Subscriber<Integer>() { Subscription subscription @Override void . . . Read more
Estoy utilizando akka http y streams para cumplir las solicitudes de API. Cuando la solicitud es inválida, quiero devolver un 400 y si es válida, quiero continuar con la computación y devolver el resultado posteriormente. El problema al que me enfrento es que el Payload que recibo de la solicitud . . . Read more
Me siento confundido cuando veo el código de muestra de ReactiveSwift, porque intuitivamente se espera que el observador reciba eventos. ¿Por qué se diseñó Observer con el método send(_:)? // Signal.pipe es una forma de controlar manualmente una señal. // El observador devuelto se puede utilizar para enviar valores a . . . Read more