spring-framework

Spring Framework

Tree: 89ce63f1f3

Simon Baslé 6d9a2eb9b8 Improve fix of duplicate upstream subscription during reactive cache put This commit fixes an issue where a Cacheable method which returns a Flux (or multi-value publisher) will be invoked once, but the returned publisher is actually subscribed twice. The previous fix `988f3630c` would cause the cached elements to depend on the first usage pattern / request pattern, which is likely to be too confusing to users. This fix reintroduces the notion of exhausting the original Flux by having a second subscriber dedicated to that, but uses `refCount(2)` to ensure that the original `Flux` returned by the cached method is still only subscribed once. Closes gh-32370	2 years ago
..
java/org/springframework	Improve fix of duplicate upstream subscription during reactive cache put	2 years ago
resources	Polishing	4 years ago

Simon Baslé 6d9a2eb9b8 Improve fix of duplicate upstream subscription during reactive cache put

This commit fixes an issue where a Cacheable method which returns a
Flux (or multi-value publisher) will be invoked once, but the returned
publisher is actually subscribed twice.

The previous fix 988f3630c would cause the cached elements to depend on
the first usage pattern / request pattern, which is likely to be too
confusing to users. This fix reintroduces the notion of exhausting the
original Flux by having a second subscriber dedicated to that, but uses
`refCount(2)` to ensure that the original `Flux` returned by the cached
method is still only subscribed once.

Closes gh-32370

2 years ago

java/org/springframework Improve fix of duplicate upstream subscription during reactive cache put 2 years ago

resources Polishing 4 years ago