Skip to content

Commit 0621d9d

Browse files
zhengyu123zhengyu123
committed
8226602: Test convenience reactive primitives from java.net.http with RS TCK
Backport-of: 3395bb5
1 parent 6722cee commit 0621d9d

File tree

57 files changed

+9984
-0
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

57 files changed

+9984
-0
lines changed

‎test/jdk/java/net/httpclient/reactivestreams-tck-tests/BodyPublishersFromPublisher.java

+53
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,53 @@
1+
/*
2+
* Copyright (c) 2019, Oracle and/or its affiliates. All rights reserved.
3+
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4+
*
5+
* This code is free software; you can redistribute it and/or modify it
6+
* under the terms of the GNU General Public License version 2 only, as
7+
* published by the Free Software Foundation.
8+
*
9+
* This code is distributed in the hope that it will be useful, but WITHOUT
10+
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11+
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
12+
* version 2 for more details (a copy is included in the LICENSE file that
13+
* accompanied this code).
14+
*
15+
* You should have received a copy of the GNU General Public License version
16+
* 2 along with this work; if not, write to the Free Software Foundation,
17+
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
18+
*
19+
* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
20+
* or visit www.oracle.com if you need additional information or have any
21+
* questions.
22+
*/
23+
24+
import org.reactivestreams.tck.TestEnvironment;
25+
import org.reactivestreams.tck.flow.FlowPublisherVerification;
26+
27+
import java.net.http.HttpRequest.BodyPublishers;
28+
import java.nio.ByteBuffer;
29+
import java.util.concurrent.Flow.Publisher;
30+
import java.util.stream.Stream;
31+
32+
/* See TckDriver.java for more information */
33+
public class BodyPublishersFromPublisher
34+
extends FlowPublisherVerification<ByteBuffer> {
35+
36+
public BodyPublishersFromPublisher() {
37+
super(new TestEnvironment(450L));
38+
}
39+
40+
@Override
41+
public Publisher<ByteBuffer> createFlowPublisher(long nElements) {
42+
Stream<ByteBuffer> buffers =
43+
Stream.generate(() -> S.bufferOfNRandomBytes(1024))
44+
.limit(nElements);
45+
Publisher<ByteBuffer> pub = S.publisherOfStream(buffers);
46+
return BodyPublishers.fromPublisher(pub);
47+
}
48+
49+
@Override
50+
public Publisher<ByteBuffer> createFailedFlowPublisher() {
51+
return BodyPublishers.fromPublisher(S.newErroredPublisher());
52+
}
53+
}

‎test/jdk/java/net/httpclient/reactivestreams-tck-tests/BodyPublishersNoBody.java

+53
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,53 @@
1+
/*
2+
* Copyright (c) 2019, Oracle and/or its affiliates. All rights reserved.
3+
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4+
*
5+
* This code is free software; you can redistribute it and/or modify it
6+
* under the terms of the GNU General Public License version 2 only, as
7+
* published by the Free Software Foundation.
8+
*
9+
* This code is distributed in the hope that it will be useful, but WITHOUT
10+
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11+
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
12+
* version 2 for more details (a copy is included in the LICENSE file that
13+
* accompanied this code).
14+
*
15+
* You should have received a copy of the GNU General Public License version
16+
* 2 along with this work; if not, write to the Free Software Foundation,
17+
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
18+
*
19+
* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
20+
* or visit www.oracle.com if you need additional information or have any
21+
* questions.
22+
*/
23+
24+
import org.reactivestreams.tck.TestEnvironment;
25+
import org.reactivestreams.tck.flow.FlowPublisherVerification;
26+
27+
import java.net.http.HttpRequest.BodyPublishers;
28+
import java.nio.ByteBuffer;
29+
import java.util.concurrent.Flow.Publisher;
30+
31+
/* See TckDriver.java for more information */
32+
public class BodyPublishersNoBody
33+
extends FlowPublisherVerification<ByteBuffer> {
34+
35+
public BodyPublishersNoBody() {
36+
super(new TestEnvironment(450L));
37+
}
38+
39+
@Override
40+
public Publisher<ByteBuffer> createFlowPublisher(long nElements) {
41+
return BodyPublishers.noBody();
42+
}
43+
44+
@Override
45+
public Publisher<ByteBuffer> createFailedFlowPublisher() {
46+
return null;
47+
}
48+
49+
@Override
50+
public long maxElementsFromPublisher() {
51+
return 0;
52+
}
53+
}

‎test/jdk/java/net/httpclient/reactivestreams-tck-tests/BodyPublishersOfByteArray.java

+56
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,56 @@
1+
/*
2+
* Copyright (c) 2019, Oracle and/or its affiliates. All rights reserved.
3+
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4+
*
5+
* This code is free software; you can redistribute it and/or modify it
6+
* under the terms of the GNU General Public License version 2 only, as
7+
* published by the Free Software Foundation.
8+
*
9+
* This code is distributed in the hope that it will be useful, but WITHOUT
10+
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11+
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
12+
* version 2 for more details (a copy is included in the LICENSE file that
13+
* accompanied this code).
14+
*
15+
* You should have received a copy of the GNU General Public License version
16+
* 2 along with this work; if not, write to the Free Software Foundation,
17+
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
18+
*
19+
* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
20+
* or visit www.oracle.com if you need additional information or have any
21+
* questions.
22+
*/
23+
24+
import org.reactivestreams.tck.TestEnvironment;
25+
import org.reactivestreams.tck.flow.FlowPublisherVerification;
26+
27+
import java.net.http.HttpRequest.BodyPublishers;
28+
import java.nio.ByteBuffer;
29+
import java.util.concurrent.Flow.Publisher;
30+
31+
/* See TckDriver.java for more information */
32+
public class BodyPublishersOfByteArray
33+
extends FlowPublisherVerification<ByteBuffer> {
34+
35+
private static final int ELEMENT_SIZE = 16 * 1024;
36+
37+
public BodyPublishersOfByteArray() {
38+
super(new TestEnvironment(450L));
39+
}
40+
41+
@Override
42+
public Publisher<ByteBuffer> createFlowPublisher(long nElements) {
43+
byte[] b = S.arrayOfNRandomBytes(nElements * ELEMENT_SIZE);
44+
return BodyPublishers.ofByteArray(b);
45+
}
46+
47+
@Override
48+
public Publisher<ByteBuffer> createFailedFlowPublisher() {
49+
return null;
50+
}
51+
52+
@Override
53+
public long maxElementsFromPublisher() {
54+
return 21;
55+
}
56+
}

‎test/jdk/java/net/httpclient/reactivestreams-tck-tests/BodyPublishersOfByteArrays.java

+53
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,53 @@
1+
/*
2+
* Copyright (c) 2019, Oracle and/or its affiliates. All rights reserved.
3+
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4+
*
5+
* This code is free software; you can redistribute it and/or modify it
6+
* under the terms of the GNU General Public License version 2 only, as
7+
* published by the Free Software Foundation.
8+
*
9+
* This code is distributed in the hope that it will be useful, but WITHOUT
10+
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11+
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
12+
* version 2 for more details (a copy is included in the LICENSE file that
13+
* accompanied this code).
14+
*
15+
* You should have received a copy of the GNU General Public License version
16+
* 2 along with this work; if not, write to the Free Software Foundation,
17+
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
18+
*
19+
* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
20+
* or visit www.oracle.com if you need additional information or have any
21+
* questions.
22+
*/
23+
24+
import org.reactivestreams.tck.TestEnvironment;
25+
import org.reactivestreams.tck.flow.FlowPublisherVerification;
26+
27+
import java.net.http.HttpRequest.BodyPublishers;
28+
import java.nio.ByteBuffer;
29+
import java.util.Collections;
30+
import java.util.concurrent.Flow.Publisher;
31+
32+
/* See TckDriver.java for more information */
33+
public class BodyPublishersOfByteArrays
34+
extends FlowPublisherVerification<ByteBuffer> {
35+
36+
private static final int ELEMENT_SIZE = 16 * 1024;
37+
38+
public BodyPublishersOfByteArrays() {
39+
super(new TestEnvironment(450L));
40+
}
41+
42+
@Override
43+
public Publisher<ByteBuffer> createFlowPublisher(long nElements) {
44+
byte[] bytes = S.arrayOfNRandomBytes(ELEMENT_SIZE);
45+
return BodyPublishers.ofByteArrays(
46+
Collections.nCopies((int) nElements, bytes));
47+
}
48+
49+
@Override
50+
public Publisher<ByteBuffer> createFailedFlowPublisher() {
51+
return null;
52+
}
53+
}

‎test/jdk/java/net/httpclient/reactivestreams-tck-tests/BodyPublishersOfFile.java

+72
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,72 @@
1+
/*
2+
* Copyright (c) 2019, Oracle and/or its affiliates. All rights reserved.
3+
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4+
*
5+
* This code is free software; you can redistribute it and/or modify it
6+
* under the terms of the GNU General Public License version 2 only, as
7+
* published by the Free Software Foundation.
8+
*
9+
* This code is distributed in the hope that it will be useful, but WITHOUT
10+
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11+
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
12+
* version 2 for more details (a copy is included in the LICENSE file that
13+
* accompanied this code).
14+
*
15+
* You should have received a copy of the GNU General Public License version
16+
* 2 along with this work; if not, write to the Free Software Foundation,
17+
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
18+
*
19+
* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
20+
* or visit www.oracle.com if you need additional information or have any
21+
* questions.
22+
*/
23+
24+
import org.reactivestreams.tck.TestEnvironment;
25+
import org.reactivestreams.tck.flow.FlowPublisherVerification;
26+
27+
import java.io.IOException;
28+
import java.io.UncheckedIOException;
29+
import java.net.http.HttpRequest.BodyPublishers;
30+
import java.nio.ByteBuffer;
31+
import java.nio.file.Files;
32+
import java.nio.file.Path;
33+
import java.util.concurrent.Flow.Publisher;
34+
import java.util.concurrent.atomic.AtomicLong;
35+
36+
/* See TckDriver.java for more information */
37+
public class BodyPublishersOfFile
38+
extends FlowPublisherVerification<ByteBuffer> {
39+
40+
private static final int ELEMENT_SIZE = 16 * 1024;
41+
private static final AtomicLong UNIQUE_NUMBERS = new AtomicLong();
42+
43+
public BodyPublishersOfFile() {
44+
super(new TestEnvironment(450L));
45+
}
46+
47+
@Override
48+
public Publisher<ByteBuffer> createFlowPublisher(long nElements) {
49+
try {
50+
Path f = createFile(nElements * ELEMENT_SIZE);
51+
return BodyPublishers.ofFile(f);
52+
} catch (IOException e) {
53+
throw new UncheckedIOException(e);
54+
}
55+
}
56+
57+
private static Path createFile(long nBytes) throws IOException {
58+
String name = "f" + UNIQUE_NUMBERS.getAndIncrement();
59+
Path f = Files.createFile(Path.of(name));
60+
return Files.write(f, S.arrayOfNRandomBytes(nBytes));
61+
}
62+
63+
@Override
64+
public Publisher<ByteBuffer> createFailedFlowPublisher() {
65+
return null;
66+
}
67+
68+
@Override
69+
public long maxElementsFromPublisher() {
70+
return 21;
71+
}
72+
}

‎test/jdk/java/net/httpclient/reactivestreams-tck-tests/BodyPublishersOfInputStream.java

+51
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,51 @@
1+
/*
2+
* Copyright (c) 2019, Oracle and/or its affiliates. All rights reserved.
3+
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4+
*
5+
* This code is free software; you can redistribute it and/or modify it
6+
* under the terms of the GNU General Public License version 2 only, as
7+
* published by the Free Software Foundation.
8+
*
9+
* This code is distributed in the hope that it will be useful, but WITHOUT
10+
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11+
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
12+
* version 2 for more details (a copy is included in the LICENSE file that
13+
* accompanied this code).
14+
*
15+
* You should have received a copy of the GNU General Public License version
16+
* 2 along with this work; if not, write to the Free Software Foundation,
17+
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
18+
*
19+
* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
20+
* or visit www.oracle.com if you need additional information or have any
21+
* questions.
22+
*/
23+
24+
import org.reactivestreams.tck.TestEnvironment;
25+
import org.reactivestreams.tck.flow.FlowPublisherVerification;
26+
27+
import java.io.InputStream;
28+
import java.net.http.HttpRequest.BodyPublishers;
29+
import java.nio.ByteBuffer;
30+
import java.util.concurrent.Flow.Publisher;
31+
import java.util.function.Supplier;
32+
33+
/* See TckDriver.java for more information */
34+
public class BodyPublishersOfInputStream
35+
extends FlowPublisherVerification<ByteBuffer> {
36+
37+
public BodyPublishersOfInputStream() {
38+
super(new TestEnvironment(450L));
39+
}
40+
41+
@Override
42+
public Publisher<ByteBuffer> createFlowPublisher(long nElements) {
43+
Supplier<InputStream> s = () -> S.inputStreamOfNReads((int) nElements);
44+
return BodyPublishers.ofInputStream(s);
45+
}
46+
47+
@Override
48+
public Publisher<ByteBuffer> createFailedFlowPublisher() {
49+
return null;
50+
}
51+
}

0 commit comments

Comments
 (0)