Skip to content

Commit 919e478

Browse files
committed
SubscriberAdapter.subscriber should be final, not volatile
1 parent afc4a0f commit 919e478

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

Diff for: client/src/main/java/org/asynchttpclient/netty/request/body/NettyReactiveStreamsBody.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ public void write(Channel channel, NettyResponseFuture<?> future) throws IOExcep
6767
}
6868

6969
private static class SubscriberAdapter implements Subscriber<ByteBuf> {
70-
private volatile Subscriber<HttpContent> subscriber;
70+
private final Subscriber<HttpContent> subscriber;
7171

7272
public SubscriberAdapter(Subscriber<HttpContent> subscriber) {
7373
this.subscriber = subscriber;

0 commit comments

Comments
 (0)