diff -r c59f36ed7b52 -r 33bb8c970770 src/java.net.http/share/classes/jdk/internal/net/http/RequestPublishers.java --- a/src/java.net.http/share/classes/jdk/internal/net/http/RequestPublishers.java Fri Jun 28 09:12:49 2019 +0200 +++ b/src/java.net.http/share/classes/jdk/internal/net/http/RequestPublishers.java Fri Jun 28 11:26:07 2019 +0100 @@ -59,7 +59,6 @@ private RequestPublishers() { } public static class ByteArrayPublisher implements BodyPublisher { - private volatile Flow.Publisher delegate; private final int length; private final byte[] content; private final int offset; @@ -99,7 +98,7 @@ @Override public void subscribe(Flow.Subscriber subscriber) { List copy = copy(content, offset, length); - this.delegate = new PullPublisher<>(copy); + var delegate = new PullPublisher<>(copy); delegate.subscribe(subscriber); } @@ -111,7 +110,6 @@ // This implementation has lots of room for improvement. public static class IterablePublisher implements BodyPublisher { - private volatile Flow.Publisher delegate; private final Iterable content; private volatile long contentLength; @@ -174,7 +172,7 @@ @Override public void subscribe(Flow.Subscriber subscriber) { Iterable iterable = this::iterator; - this.delegate = new PullPublisher<>(iterable); + var delegate = new PullPublisher<>(iterable); delegate.subscribe(subscriber); }