Fix SubscriberInputStream.resume()

See gh-35978

Signed-off-by: Johnny Lim <izeye@naver.com>
This commit is contained in:
Johnny Lim
2025-12-08 16:10:05 +01:00
committed by Brian Clozel
parent 12c3dc0cbe
commit feb77f924a
@@ -185,7 +185,7 @@ final class SubscriberInputStream extends InputStream implements Subscriber<Data
}
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);