All generic questions around Reactor. For advanced questions you can also try #reactor-core and #reactor-netty
Receiver is already closed)
.connectionMono is a new to me..
Hi there. I'm still in process of learning reactive programming. Please help with such a simple task - I want to expose an endpoint simply returning Flux<MyStructure> (response of some remote call). It's easy and it's just like doing
@GetMapping
public Flux<MyStructure> find() {...
return remoteService.findAll(param1, param2); //findAll returns Flux<MyStructure>
}Question is - what if I would to wrap response into another structure so that it's not
[{name: name1}, {name: name2}]but
{data: [{name: name1}, {name: name2}]}I assume I should first create wrapper class and return Mono<WrapperClass>. If yes - how to build the response.
return remoteService.findAll(param1, param2)
.collectList()
.map(myStructure -> buildNewStructure(myStructure);
NewStructure buildNewStructure(MyStructure myStructure) {
...
}
@62mkv - I'am in a Java App with Reactor included. Technically i'am in a Spring application but without Webflux and Netty. I'am just using Reactor. Thats working fine.
Now i have a WebRequest with retryBackOff. On Shutdown its directly killed, but i need a hook to mark that this request is canceled. Some example:
String executionId = execution.getId();
service.doWebRequest(param)
.retryBackoff(3, Duration.ofSeconds(30), Duration.ofSeconds(30))
.doOnError(e -> createIncident(executionId , e))
.doOnCancel(() -> createIncident(executionId))
.subscribe(response -> {
...
processEngine.getRuntimeService().signal(executionId, callbackPayload);
});I need to call createIncident on shutdown hook ...
@Bean and implement a DisposableBean .. probably
subscription as well (or instead)
ClientHttpConnector, the default one seems to be Netty based. So, might be worth asking in https://gitter.im/reactor/reactor-netty?
also see from the channel description:
For advanced questions you can also try #reactor-core