40 import java.security.PrivilegedExceptionAction;

    40 import java.security.PrivilegedExceptionAction;

    41 import java.util.ArrayList;

    41 import java.util.ArrayList;

    42 import java.util.Iterator;

    42 import java.util.Iterator;

    43 import java.util.List;

    43 import java.util.List;

    44 import java.util.NoSuchElementException;

    44 import java.util.NoSuchElementException;

    46 import java.util.concurrent.ConcurrentLinkedQueue;

    45 import java.util.concurrent.ConcurrentLinkedQueue;

    47 import java.util.concurrent.Flow;

    46 import java.util.concurrent.Flow;

    48 import java.util.function.Supplier;

    47 import java.util.function.Supplier;

    49 import jdk.incubator.http.HttpRequest.BodyPublisher;

    48 import jdk.incubator.http.HttpRequest.BodyPublisher;

    50 import jdk.incubator.http.internal.common.Utils;

    49 import jdk.incubator.http.internal.common.Utils;

   269         StreamIterator(InputStream is, Supplier<? extends ByteBuffer> bufSupplier) {

   268         StreamIterator(InputStream is, Supplier<? extends ByteBuffer> bufSupplier) {

   270             this.is = is;

   269             this.is = is;

   271             this.bufSupplier = bufSupplier;

   270             this.bufSupplier = bufSupplier;

   272         }

   271         }

   273 

   272 

   277 

   276 

   278         private int read() {

   277         private int read() {

   279             nextBuffer = bufSupplier.get();

   278             nextBuffer = bufSupplier.get();

   280             nextBuffer.clear();

   279             nextBuffer.clear();

   281             byte[] buf = nextBuffer.array();

   280             byte[] buf = nextBuffer.array();