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