Oleh Dokuka

closes #3138 Signed-off-by: Oleh Dokuka

Sync fusion support in reworked lazy mono stack

1

Sync fusion can be a nice improvement for the reworked lazy mono for scenarios where the source is static data source follow up for #3081

Ensure `Subscription#request` follows Reactive Streams 2.7 rule

1

The following list of operators does concurrent `Subscription#request` invocation: 1. GroupBy 2. WindowTimeout 3. TBD

Implement backpressure support in `.bufferXXX`/`.windowXXX` operators

13

Revise all the buffer/window operators to make sure they are following the concept of backpressure. Rework specific if needed to follow the approach researched in #3054

Discard vs. Drop

4

# problem It seems that similar issues were raised in the past, but I feel I'm not convinced enough to agree. 1) It seems (from @smaldini words from #1381) that...

Improves fuse-enabled operator

1

This PR is intended to consolide fusion-enabled operators and their relationships with each other if fusion is enabled and the downstream gets access to the queue of the upstream. The...

This PR drafts a simple implementation of stats explained in #2219 Signed-off-by: Oleh Dokuka

provides stats operators and supporting utility

2

This PR introduces a Stats utility that allows stats reporting to a logger ## Motivation Usually, it is challenging to analyze what is going on within your data pipeline. Metrics...

ConditionalSubscriber support where it is missed

7

This PR provides [`ConditionalSubscriber`](https://github.com/reactor/reactor-core/blob/628258f644bdddd095e72d1fc81c5d6ac0e3fa12/reactor-core/src/main/java/reactor/core/Fuseable.java#L60) fusion support in common operator: - [x] FluxSubscribeOn - [ ] FluxSkip - [ ] FluxRepeat - [ ] FluxRepeatPredicate - [ ] FluxRetry - [...

Implementation of FluxLimitRate

7

This PR provides an implementation of Queue-free Rate Limiter (see #1841)