The goal of my springBoot webflux r2dbc application is Controller accepts a Request including a list of DB UPDATE or INSERT details, and Response a result summ
In a Webflux server, detect function first looks up 2 redis hash value, and then do a heavy CPU calculation using the redis returned value, and then save result
I'm joining development on an existing SwiftUI / Combine iOS project, which is my first exposure to the technology. The names of functions like assign(to:on:) a
I have a fundamental question about reactive programming in react. As you know, a react component re-renders only if one of its props changes and does not aware
I have a part of code that checks if two observables are up to date and returns the second observable if they are: combineLatest([$source1, $source2]).pipe( f
When composing hot observables in a class using Observable.Create, I will follow the pattern of creating a lazily evaluated field which calls a private IObserva
I am using Flux<Document> in reactive, so as to make my Rest Service reactive. I am returning ResponseEntity<Flux<Document>> as response to my
I have a WebFilter that injects a context public class MyWebFilter implements WebFilter { @Override public Mono<Void> filter(ServerWebExchange exchang
Recently I have been working with WebClient. I am creating both a sync request and an async request. In a sync request, I am able to catch WebClientResponseExce
I need to get the request body as a raw JSON string in my controller. I'm using Spring WebFlux. If I could change @PostMapper function signature, it will be so
I am new in the reactive programming world. I am currently working in a Java reactive application using the Mutiny library. I need to develop a loop that waits
This question has effectively been asked before (Combine assign publisher to PassthroughSubject) but the answer assumed the architecture of the question's examp
I've a reactive API which receives the following String (image below). I want to process these ID's and perform a search query to my MongoDB and return a Flux w
Following is an excerpt from here: The foundation for a reactive system is message-passing, which creates a temporal boundary between components that allows th
I have this method which gets redirection url and then redirect to that url private Mono<Void> redirectToUrl(ServerHttpResponse response, String status
We wrote a small Spring Boot REST application, which performs a REST request on another REST endpoint. @RequestMapping("/api/v1") @SpringBootApplication @RestC
The sample operation takes the first entry from flux after the duration. How can I make it such that I take the first entry on subscribe and then do the rest?
Suppose I have this method: public static Mono<String> getData2() { return Mono.just("7"); } I want to call this method, get back the string, convert
In Spring Data, we have PagingAndSortingRepository which inherits from CrudRepository. In reactive Spring Data, we only have ReactiveSortingRepository which in
I have been looking at spring-data-r2dbc for reactive DB access. But it seems it doesn't provide any ORM suppport, as stated on the project's page, it is not an