32 import java.util.concurrent.Flow.Subscription; |
32 import java.util.concurrent.Flow.Subscription; |
33 import java.util.concurrent.Phaser; |
33 import java.util.concurrent.Phaser; |
34 import java.util.concurrent.SubmissionPublisher; |
34 import java.util.concurrent.SubmissionPublisher; |
35 import java.util.function.IntSupplier; |
35 import java.util.function.IntSupplier; |
36 import java.util.stream.IntStream; |
36 import java.util.stream.IntStream; |
37 import jdk.incubator.http.HttpResponse.BodySubscriber; |
37 import java.net.http.HttpResponse.BodySubscriber; |
38 import org.testng.annotations.DataProvider; |
38 import org.testng.annotations.DataProvider; |
39 import org.testng.annotations.Test; |
39 import org.testng.annotations.Test; |
40 import static java.lang.Long.MAX_VALUE; |
40 import static java.lang.Long.MAX_VALUE; |
41 import static java.lang.Long.MIN_VALUE; |
41 import static java.lang.Long.MIN_VALUE; |
42 import static java.lang.System.out; |
42 import static java.lang.System.out; |
43 import static java.nio.ByteBuffer.wrap; |
43 import static java.nio.ByteBuffer.wrap; |
44 import static java.util.concurrent.TimeUnit.SECONDS; |
44 import static java.util.concurrent.TimeUnit.SECONDS; |
45 import static jdk.incubator.http.HttpResponse.BodySubscriber.buffering; |
45 import static java.net.http.HttpResponse.BodySubscriber.buffering; |
46 import static org.testng.Assert.*; |
46 import static org.testng.Assert.*; |
47 |
47 |
48 /* |
48 /* |
49 * @test |
49 * @test |
50 * @summary Test for HttpResponse.BodySubscriber.buffering() onError/onComplete |
50 * @summary Test for HttpResponse.BodySubscriber.buffering() onError/onComplete |