1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27 package org.apache.hc.client5.testing.async;
28
29 import java.util.Arrays;
30 import java.util.Collection;
31
32 import org.apache.hc.client5.http.impl.async.HttpAsyncClients;
33 import org.apache.hc.client5.http.impl.async.MinimalH2AsyncClient;
34 import org.apache.hc.client5.http.ssl.DefaultClientTlsStrategy;
35 import org.apache.hc.client5.testing.SSLTestContexts;
36 import org.apache.hc.core5.http.HttpHost;
37 import org.apache.hc.core5.http.URIScheme;
38 import org.apache.hc.core5.http2.config.H2Config;
39 import org.apache.hc.core5.reactor.IOReactorConfig;
40 import org.junit.runner.RunWith;
41 import org.junit.runners.Parameterized;
42
43 @RunWith(Parameterized.class)
44 public class TestH2MinimalReactive extends AbstractHttpReactiveFundamentalsTest<MinimalH2AsyncClient> {
45
46 @Parameterized.Parameters(name = "{0}")
47 public static Collection<Object[]> protocols() {
48 return Arrays.asList(new Object[][]{
49 { URIScheme.HTTP },
50 { URIScheme.HTTPS },
51 });
52 }
53
54 public TestH2MinimalReactive(final URIScheme scheme) {
55 super(scheme);
56 }
57
58 @Override
59 protected MinimalH2AsyncClient createClient() throws Exception {
60 final IOReactorConfig ioReactorConfig = IOReactorConfig.custom()
61 .setSoTimeout(TIMEOUT)
62 .build();
63 return HttpAsyncClients.createHttp2Minimal(
64 H2Config.DEFAULT, ioReactorConfig, new DefaultClientTlsStrategy(SSLTestContexts.createClientSSLContext()));
65 }
66
67 @Override
68 public HttpHost start() throws Exception {
69 return super.start(null, H2Config.DEFAULT);
70 }
71
72 }