Browse Source

Polishing contribution

Closes gh-35978
6.2.x
Brian Clozel 2 months ago
parent
commit
3b1fa369b4
  1. 2
      spring-web/src/main/java/org/springframework/http/client/SubscriberInputStream.java

2
spring-web/src/main/java/org/springframework/http/client/SubscriberInputStream.java

@ -209,7 +209,7 @@ final class SubscriberInputStream<T> extends InputStream implements Flow.Subscri @@ -209,7 +209,7 @@ final class SubscriberInputStream<T> extends InputStream implements Flow.Subscri
}
private void resume() {
if (this.parkedThread != READY) {
if (this.parkedThread.get() != READY) {
Object old = this.parkedThread.getAndSet(READY);
if (old != READY) {
LockSupport.unpark((Thread) old);

Loading…
Cancel
Save