We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ec33b42 commit 17e6cf1Copy full SHA for 17e6cf1
spring-web/src/main/java/org/springframework/http/server/reactive/AbstractServerHttpResponse.java
@@ -18,6 +18,7 @@
18
19
import java.util.ArrayList;
20
import java.util.List;
21
+import java.util.concurrent.atomic.AtomicBoolean;
22
import java.util.concurrent.atomic.AtomicReference;
23
import java.util.function.Supplier;
24
@@ -213,7 +214,7 @@ public final Mono<Void> writeWith(Publisher<? extends DataBuffer> body) {
213
214
return ((Mono<? extends DataBuffer>) body)
215
.flatMap(buffer -> {
216
touchDataBuffer(buffer);
- AtomicReference<Boolean> subscribed = new AtomicReference<>(false);
217
+ AtomicBoolean subscribed = new AtomicBoolean();
218
return doCommit(
219
() -> {
220
try {
0 commit comments