In a test method an instance of org.springframework.web.reactive.function.client.ClientRequest is received. I want to verify its HttpMethod, URI and body. It is quite obvious how to get everythin...

I want to use DOM in angular project like this Rx.DOM.jsonpRequest but DOM is not available on Rx which Im importing like this import Rx = require('rxjs'); I also tried to import rxjs dom ...

I have a Asyn call thrift interface: public CompletableFuture<List<Long>> getFavourites(Long userId){ CompletableFuture<List<Long>> future = new CompletableFuture(); OctoT...

I am using Angular 11 and I am accessing an observable in the template of my component with async pipe. First load of the route, everything works perfectly fine. No error. When I navigate away from...

I would like to AWS sign my HTTP request fired by reactive WebClient of Spring. To sign the request I need access to the followings: URL, HTTP method, query parameters, headers and request body byt...

The following function: private Boolean canDoIt(Parameter param) { return myService .getMyObjectInReactiveWay(param) .map(myObject -> myService.checkMyObjectInImperativeWay(myObject)) .block...

How to plug a cancellation token into an existing IObservable pipeline before calling Publish on it (i.e., before it becomes an IConnectableObservable)? This must be a part of a cold observable pip...

I have started using WebClient in my Spring boot project recently. Can somebody throw some light on the differences/usages between exchange and retrieve methods in WebClient. I understand that exch...

I'm learning reactive programming using RxJS and encounter a case when I need to read a file line-by-line. Actually I solved it using a solution likes: https://gist.github.com/yvele/447555b1c50609...

Short example of what I'm having trouble understanding: Stream<int> getNumbersWithException() async* { for (var i = 0; i < 10; i++) { yield i; if (i == 3) throw Exception(); } } With ...

By using Blockhound io.projectreactor.tools blockhound-junit-platform i found out that UUID.randomUUID is a blocking call which is a problem for us since we are using Spring boot Webflux version 2....

Does there exist something equivalent to the async pipe that I could use inside a component like this @Component({ selector: 'my-component', }) export class myComponent { myObservable$: Obs...

I know it is possible to chain Mono's, for ex,... Mono<String> resultAMono = loadA(); Mono<String> resultBMono = resultA.flatMap(resultA -> loadB()); This will chain and resultBMo...

I'm struggling to create a countdown timer using Observables, the examples at http://reactivex.io/documentation/operators/timer.html do not seem to work. In this specific example the error related ...

I am trying to use Webflux to stream a generated file to another location, however, if the generation of the file ran into an error, the api returns success, but with a DTO detailing the errors whi...

Small question on how to add delay in a method but in a non blocking way please. A very popular way to simulate long processes is to use Thread.sleep(); However, for project Reactor, this is a bloc...

The rxjava doc definition of switchmap is rather vague and it links to the same page as flatmap. What is the difference between the two operators?

Say we have an instance of o.s.w.reactive.function.server.ServerResponse. What is the proper way to fetch the contents of its body, in other words how to implement fetchBodyAsString function? tes...

Let consider following codebase: @GetMapping("/test") public Mono<org.springframework.security.oauth2.jwt.Jwt> test { Mono<org.springframework.security.oauth2.jwt.Jwt> mono =...

I would like to build a Repository class that returns a Single<Something>. The class should first look in a Cache which returns Maybe<Something> and if the Maybe completes go off to my...

I am working on a portfolio and I'm using react.js. I simply want to click an image, for example, a StackOverflow icon, and be able to redirect to the page. I'm seeing all sorts of different ways t...

I've read that there is an option to make a blocking call using Mono. So I tried to write several code snippets: A) Mono.just("qwerty") .subscribeOn(Schedulers.boundedElastic()) .publishO...

I'm attempting to achieve the following in the method below Get All Cars from Dealer X Create wrapper object that stores a set of all cars and another set of all manufactures 2a. Populate Ca...

We wrote a small Spring Boot REST application, which performs a REST request on another REST endpoint. @RequestMapping("/api/v1") @SpringBootApplication @RestController @Slf4j public class Applica...

I'm trying to setup Spring Security with Spring Web Flux. I don't understand how to manually set the SecurityContext with ReactiveSecurityContextHolder. Do you have any resource or hint? Take for e...