python (12.9k questions)

javascript (9.2k questions)

reactjs (4.7k questions)

java (4.2k questions)

java (4.2k questions)

c# (3.5k questions)

c# (3.5k questions)

html (3.3k questions)

Questions - webflux

Unit testing retry in Spring Webflux with mocked response

During unit testing retry the response of the mock seems cached, or most probably I am doing something wrong. I am trying to request something, if error happened then retry twice with delay of 1 secon...
test-img

Hatik

java

project-reactor

webflux

retrywhen

Votes: 0

Answers: 1

Latest Answer

someInjectedService.doSomething(...) will indeed technically be called only once. You could use Mono.defer(() -> someInjectedService.doSomething(someParam)) instead, to ensure the method is effecti...
test-img

sp00m

How can i consume a Flux<DataBuffer> with WebClient

I have this controller : @GetMapping(value = "/stream") public Flux<DataBuffer> stream() { ... return webClient.get().uri(builder.buildAndExpand(parametre...
test-img

Samshay

java

spring

stream

webclient

webflux

Votes: 0

Answers: 0

Spring Boot webflux - offload requests to a different threadpool

I'm using webflux with netty reactor. The framework allows registering a regular blocking method (e.g that returns a string or some POJO) in a @RestController class. The issue with that is the request...
test-img

O. Gur

spring

spring-boot

blocking

webflux

Votes: 0

Answers: 0

Convert Webflux API stream response to List&lt;Object&gt;

I am very new to reactive programming. I am consuming a webflux API which is returning stream response ( application/stream+json ). My task is to call the API and convert response to List. My code sni...
test-img

ysn

reactive-programming

webflux

Votes: 0

Answers: 2

Latest Answer

Using block() you switch to imperative code. So, here ClientResponse res = webClient.method(HttpMethod.GET) .uri("uri") .header("Authorization"...
test-img

lkatiforis

Posts

Questions

Blogs

Jobs