Sage Pierce

FluxGroupBy silently drops onNext signals

17

I have a use case where I'm using `Flux::groupBy` with a relatively high cardinality of grouping (1024-4096 concurrent groups at any given time). FWIW, the use case itself is similar...

[Avro] Incompatibility with Avro >=1.9.0

39

Avro version 1.9.0 was released last month (https://mvnrepository.com/artifact/org.apache.avro/avro) and my team has run in to compatibility issues between `jackson-dataformat-avro` and this latest release. In particular, it looks to be the...

[#3821] Fix `FluxBuffer` to request 1 when buffer is not modified

9

If a Set is used as the destination in `Flux.buffer`, the stream will not hang if/when there are duplicates in a given buffer Previously, `FluxBuffer` was not taking the result...

If `Flux.buffer(int maxSize, Supplier bufferSupplier)` is invoked where the `bufferSupplier` returns a Set, the stream may hang on duplicate upstream emissions and bounded downstream request. ## Extra Context I have...