Rossen Stoyanchev
Rossen Stoyanchev
Symmetrical to #283, this ticket is for client to server streaming. If the client is not writing for some period of time, it remains unaware of a server shutdown. On...
This is how [consumeAndCancel](https://github.com/spring-projects/spring-framework/blob/44df98c82da75114081ba02364e467004252bb77/spring-webflux/src/main/java/org/springframework/web/reactive/function/BodyExtractors.java#L267-L275) is done in the `WebClient` for example. This isn't too bad but anything using `HttpClient` would need something similar and arguably Reactor Netty should have official...
Currently, `Mono#fromFuture` uses `MonoCompletionStage`, and `CompletionStage` does not have a `cancel` method. As a result, even if the `Mono` is cancelled, the future is never made aware of it.
The following results in `BubblingException` containing the `IllegalStateException`: ```java Mono.just("a").concatWith(Mono.error(new IllegalStateException("e"))) .windowUntil(s -> s.equals("b")) .concatMap(Flux::collectList) .blockLast(); ``` By comparison the following results in just the `IllegalStateException` as expected: ```java Mono.just("a").concatWith(Mono.error(new...
The project reference already [has a section](https://projectreactor.io/docs/core/release/reference/#_the_code_doondiscard_code_operator_local_hook) for the `doOnDiscard` hook. The explanation is very good, but in practice it remains tricky to reason about when the hook should be...
There is one in Spring Boot that can move into the Spring Framework. `DataSize` even has a parse method so it should be just a matter of adapting to `Converter`.
Reactor Netty 2.0 milestones are already tracking Netty 5, see https://github.com/reactor/reactor-netty/issues/1873 and related issues. We need to add server side adapters and a client connector for the same in the...
Web Flow is getting upgraded to Spring Framework 6, Java 17+ and Jakarta EE. The main branch is already building with that after https://github.com/spring-projects/spring-webflow/pull/109. It would be great to re-introduce...
`RSocketClient` implements `Disposable` which provides a way to initiate a shutdown. However, there is no good way to hold for the result, and it is important in some cases to...
If compression is enabled on client and server, the client acceptor fails with `ArrayIndexOutOfBoundsException` if it tries to access properties of `ConnectionSetupPayload`. Here is the diff with changes to the...