mirror of
https://github.com/square/okhttp.git
synced 2025-08-08 23:42:08 +03:00
Rename OkHttpClientTestingRule to OkHttpClientTestRule
This commit is contained in:
@@ -17,7 +17,7 @@ package okhttp3.internal.sse;
|
|||||||
|
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
import okhttp3.OkHttpClient;
|
import okhttp3.OkHttpClient;
|
||||||
import okhttp3.OkHttpClientTestingRule;
|
import okhttp3.OkHttpClientTestRule;
|
||||||
import okhttp3.Request;
|
import okhttp3.Request;
|
||||||
import okhttp3.mockwebserver.MockResponse;
|
import okhttp3.mockwebserver.MockResponse;
|
||||||
import okhttp3.mockwebserver.MockWebServer;
|
import okhttp3.mockwebserver.MockWebServer;
|
||||||
@@ -31,10 +31,10 @@ import static org.junit.Assert.assertEquals;
|
|||||||
|
|
||||||
public final class EventSourceHttpTest {
|
public final class EventSourceHttpTest {
|
||||||
@Rule public final MockWebServer server = new MockWebServer();
|
@Rule public final MockWebServer server = new MockWebServer();
|
||||||
@Rule public final OkHttpClientTestingRule clientTestingRule = new OkHttpClientTestingRule();
|
@Rule public final OkHttpClientTestRule clientTestRule = new OkHttpClientTestRule();
|
||||||
|
|
||||||
private final EventSourceRecorder listener = new EventSourceRecorder();
|
private final EventSourceRecorder listener = new EventSourceRecorder();
|
||||||
private OkHttpClient client = clientTestingRule.client;
|
private OkHttpClient client = clientTestRule.client;
|
||||||
|
|
||||||
@After public void after() {
|
@After public void after() {
|
||||||
listener.assertExhausted();
|
listener.assertExhausted();
|
||||||
|
@@ -21,7 +21,7 @@ import org.junit.runners.model.Statement;
|
|||||||
|
|
||||||
import static okhttp3.TestUtil.defaultClient;
|
import static okhttp3.TestUtil.defaultClient;
|
||||||
|
|
||||||
public class OkHttpClientTestingRule implements TestRule {
|
public class OkHttpClientTestRule implements TestRule {
|
||||||
public OkHttpClient client = defaultClient();
|
public OkHttpClient client = defaultClient();
|
||||||
|
|
||||||
@Override
|
@Override
|
@@ -66,7 +66,7 @@ public final class CacheTest {
|
|||||||
@Rule public MockWebServer server = new MockWebServer();
|
@Rule public MockWebServer server = new MockWebServer();
|
||||||
@Rule public MockWebServer server2 = new MockWebServer();
|
@Rule public MockWebServer server2 = new MockWebServer();
|
||||||
@Rule public InMemoryFileSystem fileSystem = new InMemoryFileSystem();
|
@Rule public InMemoryFileSystem fileSystem = new InMemoryFileSystem();
|
||||||
@Rule public final OkHttpClientTestingRule clientTestingRule = new OkHttpClientTestingRule();
|
@Rule public final OkHttpClientTestRule clientTestRule = new OkHttpClientTestRule();
|
||||||
|
|
||||||
private final HandshakeCertificates handshakeCertificates = localhost();
|
private final HandshakeCertificates handshakeCertificates = localhost();
|
||||||
private OkHttpClient client;
|
private OkHttpClient client;
|
||||||
@@ -76,7 +76,7 @@ public final class CacheTest {
|
|||||||
@Before public void setUp() throws Exception {
|
@Before public void setUp() throws Exception {
|
||||||
server.setProtocolNegotiationEnabled(false);
|
server.setProtocolNegotiationEnabled(false);
|
||||||
cache = new Cache(new File("/cache/"), Integer.MAX_VALUE, fileSystem);
|
cache = new Cache(new File("/cache/"), Integer.MAX_VALUE, fileSystem);
|
||||||
client = clientTestingRule.client.newBuilder()
|
client = clientTestRule.client.newBuilder()
|
||||||
.cache(cache)
|
.cache(cache)
|
||||||
.cookieJar(new JavaNetCookieJar(cookieManager))
|
.cookieJar(new JavaNetCookieJar(cookieManager))
|
||||||
.build();
|
.build();
|
||||||
|
@@ -107,11 +107,11 @@ public final class CallTest {
|
|||||||
@Rule public final MockWebServer server = new MockWebServer();
|
@Rule public final MockWebServer server = new MockWebServer();
|
||||||
@Rule public final MockWebServer server2 = new MockWebServer();
|
@Rule public final MockWebServer server2 = new MockWebServer();
|
||||||
@Rule public final InMemoryFileSystem fileSystem = new InMemoryFileSystem();
|
@Rule public final InMemoryFileSystem fileSystem = new InMemoryFileSystem();
|
||||||
@Rule public final OkHttpClientTestingRule clientTestingRule = new OkHttpClientTestingRule();
|
@Rule public final OkHttpClientTestRule clientTestRule = new OkHttpClientTestRule();
|
||||||
|
|
||||||
private final RecordingEventListener listener = new RecordingEventListener();
|
private final RecordingEventListener listener = new RecordingEventListener();
|
||||||
private HandshakeCertificates handshakeCertificates = localhost();
|
private HandshakeCertificates handshakeCertificates = localhost();
|
||||||
private OkHttpClient client = clientTestingRule.client.newBuilder()
|
private OkHttpClient client = clientTestRule.client.newBuilder()
|
||||||
.eventListener(listener)
|
.eventListener(listener)
|
||||||
.build();
|
.build();
|
||||||
private RecordingCallback callback = new RecordingCallback();
|
private RecordingCallback callback = new RecordingCallback();
|
||||||
@@ -933,7 +933,7 @@ public final class CallTest {
|
|||||||
|
|
||||||
/** https://github.com/square/okhttp/issues/1801 */
|
/** https://github.com/square/okhttp/issues/1801 */
|
||||||
@Test public void asyncCallEngineInitialized() throws Exception {
|
@Test public void asyncCallEngineInitialized() throws Exception {
|
||||||
OkHttpClient c = clientTestingRule.client.newBuilder()
|
OkHttpClient c = clientTestRule.client.newBuilder()
|
||||||
.addInterceptor(chain -> { throw new IOException(); })
|
.addInterceptor(chain -> { throw new IOException(); })
|
||||||
.build();
|
.build();
|
||||||
Request request = new Request.Builder().url(server.url("/")).build();
|
Request request = new Request.Builder().url(server.url("/")).build();
|
||||||
@@ -3368,7 +3368,7 @@ public final class CallTest {
|
|||||||
server.enqueue(new MockResponse()
|
server.enqueue(new MockResponse()
|
||||||
.setBody("This gets leaked."));
|
.setBody("This gets leaked."));
|
||||||
|
|
||||||
client = clientTestingRule.client.newBuilder()
|
client = clientTestRule.client.newBuilder()
|
||||||
.connectionPool(new ConnectionPool(0, 10, TimeUnit.MILLISECONDS))
|
.connectionPool(new ConnectionPool(0, 10, TimeUnit.MILLISECONDS))
|
||||||
.build();
|
.build();
|
||||||
|
|
||||||
@@ -3397,7 +3397,7 @@ public final class CallTest {
|
|||||||
server.enqueue(new MockResponse()
|
server.enqueue(new MockResponse()
|
||||||
.setBody("This gets leaked."));
|
.setBody("This gets leaked."));
|
||||||
|
|
||||||
client = clientTestingRule.client.newBuilder()
|
client = clientTestRule.client.newBuilder()
|
||||||
.connectionPool(new ConnectionPool(0, 10, TimeUnit.MILLISECONDS))
|
.connectionPool(new ConnectionPool(0, 10, TimeUnit.MILLISECONDS))
|
||||||
.build();
|
.build();
|
||||||
|
|
||||||
|
@@ -29,7 +29,6 @@ import okhttp3.mockwebserver.MockResponse;
|
|||||||
import okhttp3.mockwebserver.MockWebServer;
|
import okhttp3.mockwebserver.MockWebServer;
|
||||||
import okhttp3.tls.HandshakeCertificates;
|
import okhttp3.tls.HandshakeCertificates;
|
||||||
import okhttp3.tls.HeldCertificate;
|
import okhttp3.tls.HeldCertificate;
|
||||||
import org.junit.After;
|
|
||||||
import org.junit.Before;
|
import org.junit.Before;
|
||||||
import org.junit.Ignore;
|
import org.junit.Ignore;
|
||||||
import org.junit.Rule;
|
import org.junit.Rule;
|
||||||
@@ -40,7 +39,7 @@ import static org.junit.Assert.fail;
|
|||||||
|
|
||||||
public final class ConnectionCoalescingTest {
|
public final class ConnectionCoalescingTest {
|
||||||
@Rule public final MockWebServer server = new MockWebServer();
|
@Rule public final MockWebServer server = new MockWebServer();
|
||||||
@Rule public final OkHttpClientTestingRule clientTestingRule = new OkHttpClientTestingRule();
|
@Rule public final OkHttpClientTestRule clientTestRule = new OkHttpClientTestRule();
|
||||||
|
|
||||||
private OkHttpClient client;
|
private OkHttpClient client;
|
||||||
|
|
||||||
@@ -82,7 +81,7 @@ public final class ConnectionCoalescingTest {
|
|||||||
.sslSocketFactory(
|
.sslSocketFactory(
|
||||||
handshakeCertificates.sslSocketFactory(), handshakeCertificates.trustManager())
|
handshakeCertificates.sslSocketFactory(), handshakeCertificates.trustManager())
|
||||||
.build();
|
.build();
|
||||||
clientTestingRule.client = client;
|
clientTestRule.client = client;
|
||||||
|
|
||||||
HandshakeCertificates serverHandshakeCertificates = new HandshakeCertificates.Builder()
|
HandshakeCertificates serverHandshakeCertificates = new HandshakeCertificates.Builder()
|
||||||
.heldCertificate(certificate)
|
.heldCertificate(certificate)
|
||||||
|
@@ -25,7 +25,6 @@ import okhttp3.mockwebserver.MockResponse;
|
|||||||
import okhttp3.mockwebserver.MockWebServer;
|
import okhttp3.mockwebserver.MockWebServer;
|
||||||
import okhttp3.mockwebserver.SocketPolicy;
|
import okhttp3.mockwebserver.SocketPolicy;
|
||||||
import okhttp3.tls.HandshakeCertificates;
|
import okhttp3.tls.HandshakeCertificates;
|
||||||
import org.junit.After;
|
|
||||||
import org.junit.Rule;
|
import org.junit.Rule;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
import org.junit.rules.TestRule;
|
import org.junit.rules.TestRule;
|
||||||
@@ -38,10 +37,10 @@ import static org.junit.Assert.fail;
|
|||||||
public final class ConnectionReuseTest {
|
public final class ConnectionReuseTest {
|
||||||
@Rule public final TestRule timeout = new Timeout(30_000);
|
@Rule public final TestRule timeout = new Timeout(30_000);
|
||||||
@Rule public final MockWebServer server = new MockWebServer();
|
@Rule public final MockWebServer server = new MockWebServer();
|
||||||
@Rule public final OkHttpClientTestingRule clientTestingRule = new OkHttpClientTestingRule();
|
@Rule public final OkHttpClientTestRule clientTestRule = new OkHttpClientTestRule();
|
||||||
|
|
||||||
private HandshakeCertificates handshakeCertificates = localhost();
|
private HandshakeCertificates handshakeCertificates = localhost();
|
||||||
private OkHttpClient client = clientTestingRule.client;
|
private OkHttpClient client = clientTestRule.client;
|
||||||
|
|
||||||
@Test public void connectionsAreReused() throws Exception {
|
@Test public void connectionsAreReused() throws Exception {
|
||||||
server.enqueue(new MockResponse().setBody("a"));
|
server.enqueue(new MockResponse().setBody("a"));
|
||||||
|
@@ -31,7 +31,6 @@ import java.util.Map;
|
|||||||
import okhttp3.mockwebserver.MockResponse;
|
import okhttp3.mockwebserver.MockResponse;
|
||||||
import okhttp3.mockwebserver.MockWebServer;
|
import okhttp3.mockwebserver.MockWebServer;
|
||||||
import okhttp3.mockwebserver.RecordedRequest;
|
import okhttp3.mockwebserver.RecordedRequest;
|
||||||
import org.junit.After;
|
|
||||||
import org.junit.Rule;
|
import org.junit.Rule;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
|
|
||||||
@@ -44,9 +43,9 @@ import static org.junit.Assert.fail;
|
|||||||
|
|
||||||
/** Derived from Android's CookiesTest. */
|
/** Derived from Android's CookiesTest. */
|
||||||
public class CookiesTest {
|
public class CookiesTest {
|
||||||
@Rule public final OkHttpClientTestingRule clientTestingRule = new OkHttpClientTestingRule();
|
@Rule public final OkHttpClientTestRule clientTestRule = new OkHttpClientTestRule();
|
||||||
|
|
||||||
private OkHttpClient client = clientTestingRule.client;
|
private OkHttpClient client = clientTestRule.client;
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void testNetscapeResponse() throws Exception {
|
public void testNetscapeResponse() throws Exception {
|
||||||
|
@@ -15,7 +15,6 @@ import java.util.concurrent.RejectedExecutionException;
|
|||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
import java.util.concurrent.atomic.AtomicBoolean;
|
import java.util.concurrent.atomic.AtomicBoolean;
|
||||||
import okhttp3.RealCall.AsyncCall;
|
import okhttp3.RealCall.AsyncCall;
|
||||||
import org.junit.After;
|
|
||||||
import org.junit.Before;
|
import org.junit.Before;
|
||||||
import org.junit.Rule;
|
import org.junit.Rule;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
@@ -27,14 +26,14 @@ import static org.junit.Assert.assertTrue;
|
|||||||
import static org.junit.Assert.fail;
|
import static org.junit.Assert.fail;
|
||||||
|
|
||||||
public final class DispatcherTest {
|
public final class DispatcherTest {
|
||||||
@Rule public final OkHttpClientTestingRule clientTestingRule = new OkHttpClientTestingRule();
|
@Rule public final OkHttpClientTestRule clientTestRule = new OkHttpClientTestRule();
|
||||||
|
|
||||||
RecordingExecutor executor = new RecordingExecutor();
|
RecordingExecutor executor = new RecordingExecutor();
|
||||||
RecordingCallback callback = new RecordingCallback();
|
RecordingCallback callback = new RecordingCallback();
|
||||||
RecordingWebSocketListener webSocketListener = new RecordingWebSocketListener();
|
RecordingWebSocketListener webSocketListener = new RecordingWebSocketListener();
|
||||||
Dispatcher dispatcher = new Dispatcher(executor);
|
Dispatcher dispatcher = new Dispatcher(executor);
|
||||||
RecordingEventListener listener = new RecordingEventListener();
|
RecordingEventListener listener = new RecordingEventListener();
|
||||||
OkHttpClient client = clientTestingRule.client.newBuilder()
|
OkHttpClient client = clientTestRule.client.newBuilder()
|
||||||
.dispatcher(dispatcher)
|
.dispatcher(dispatcher)
|
||||||
.eventListener(listener)
|
.eventListener(listener)
|
||||||
.build();
|
.build();
|
||||||
|
@@ -31,7 +31,6 @@ import okhttp3.mockwebserver.internal.duplex.MockDuplexResponseBody;
|
|||||||
import okhttp3.tls.HandshakeCertificates;
|
import okhttp3.tls.HandshakeCertificates;
|
||||||
import okio.BufferedSink;
|
import okio.BufferedSink;
|
||||||
import okio.BufferedSource;
|
import okio.BufferedSource;
|
||||||
import org.junit.After;
|
|
||||||
import org.junit.Rule;
|
import org.junit.Rule;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
import org.junit.rules.TestRule;
|
import org.junit.rules.TestRule;
|
||||||
@@ -46,11 +45,11 @@ import static org.junit.Assert.fail;
|
|||||||
public final class DuplexTest {
|
public final class DuplexTest {
|
||||||
@Rule public final TestRule timeout = new Timeout(30_000, TimeUnit.MILLISECONDS);
|
@Rule public final TestRule timeout = new Timeout(30_000, TimeUnit.MILLISECONDS);
|
||||||
@Rule public final MockWebServer server = new MockWebServer();
|
@Rule public final MockWebServer server = new MockWebServer();
|
||||||
@Rule public OkHttpClientTestingRule clientTestingRule = new OkHttpClientTestingRule();
|
@Rule public OkHttpClientTestRule clientTestRule = new OkHttpClientTestRule();
|
||||||
|
|
||||||
private final RecordingEventListener listener = new RecordingEventListener();
|
private final RecordingEventListener listener = new RecordingEventListener();
|
||||||
private HandshakeCertificates handshakeCertificates = localhost();
|
private HandshakeCertificates handshakeCertificates = localhost();
|
||||||
private OkHttpClient client = clientTestingRule.client
|
private OkHttpClient client = clientTestRule.client
|
||||||
.newBuilder()
|
.newBuilder()
|
||||||
.eventListener(listener)
|
.eventListener(listener)
|
||||||
.build();
|
.build();
|
||||||
|
@@ -79,16 +79,16 @@ import static org.junit.Assume.assumeThat;
|
|||||||
public final class EventListenerTest {
|
public final class EventListenerTest {
|
||||||
public static final Matcher<Response> anyResponse = CoreMatchers.any(Response.class);
|
public static final Matcher<Response> anyResponse = CoreMatchers.any(Response.class);
|
||||||
@Rule public final MockWebServer server = new MockWebServer();
|
@Rule public final MockWebServer server = new MockWebServer();
|
||||||
@Rule public final OkHttpClientTestingRule clientTestingRule = new OkHttpClientTestingRule();
|
@Rule public final OkHttpClientTestRule clientTestRule = new OkHttpClientTestRule();
|
||||||
|
|
||||||
private final RecordingEventListener listener = new RecordingEventListener();
|
private final RecordingEventListener listener = new RecordingEventListener();
|
||||||
private final HandshakeCertificates handshakeCertificates = localhost();
|
private final HandshakeCertificates handshakeCertificates = localhost();
|
||||||
|
|
||||||
private OkHttpClient client = clientTestingRule.client;
|
private OkHttpClient client = clientTestRule.client;
|
||||||
private SocksProxy socksProxy;
|
private SocksProxy socksProxy;
|
||||||
|
|
||||||
@Before public void setUp() {
|
@Before public void setUp() {
|
||||||
client = clientTestingRule.client.newBuilder()
|
client = clientTestRule.client.newBuilder()
|
||||||
.eventListener(listener)
|
.eventListener(listener)
|
||||||
.build();
|
.build();
|
||||||
|
|
||||||
|
@@ -39,7 +39,6 @@ import okio.GzipSink;
|
|||||||
import okio.Okio;
|
import okio.Okio;
|
||||||
import okio.Sink;
|
import okio.Sink;
|
||||||
import okio.Source;
|
import okio.Source;
|
||||||
import org.junit.After;
|
|
||||||
import org.junit.Rule;
|
import org.junit.Rule;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
|
|
||||||
@@ -53,9 +52,9 @@ import static org.junit.Assert.fail;
|
|||||||
|
|
||||||
public final class InterceptorTest {
|
public final class InterceptorTest {
|
||||||
@Rule public MockWebServer server = new MockWebServer();
|
@Rule public MockWebServer server = new MockWebServer();
|
||||||
@Rule public final OkHttpClientTestingRule clientTestingRule = new OkHttpClientTestingRule();
|
@Rule public final OkHttpClientTestRule clientTestRule = new OkHttpClientTestRule();
|
||||||
|
|
||||||
private OkHttpClient client = clientTestingRule.client;
|
private OkHttpClient client = clientTestRule.client;
|
||||||
private RecordingCallback callback = new RecordingCallback();
|
private RecordingCallback callback = new RecordingCallback();
|
||||||
|
|
||||||
@Test public void applicationInterceptorsCanShortCircuitResponses() throws Exception {
|
@Test public void applicationInterceptorsCanShortCircuitResponses() throws Exception {
|
||||||
|
@@ -113,10 +113,10 @@ public final class URLConnectionTest {
|
|||||||
@Rule public final MockWebServer server = new MockWebServer();
|
@Rule public final MockWebServer server = new MockWebServer();
|
||||||
@Rule public final MockWebServer server2 = new MockWebServer();
|
@Rule public final MockWebServer server2 = new MockWebServer();
|
||||||
@Rule public final TemporaryFolder tempDir = new TemporaryFolder();
|
@Rule public final TemporaryFolder tempDir = new TemporaryFolder();
|
||||||
@Rule public final OkHttpClientTestingRule clientTestingRule = new OkHttpClientTestingRule();
|
@Rule public final OkHttpClientTestRule clientTestRule = new OkHttpClientTestRule();
|
||||||
|
|
||||||
private HandshakeCertificates handshakeCertificates = localhost();
|
private HandshakeCertificates handshakeCertificates = localhost();
|
||||||
private OkHttpClient client = clientTestingRule.client;
|
private OkHttpClient client = clientTestRule.client;
|
||||||
private @Nullable Cache cache;
|
private @Nullable Cache cache;
|
||||||
|
|
||||||
@Before public void setUp() {
|
@Before public void setUp() {
|
||||||
|
@@ -24,7 +24,6 @@ import java.util.concurrent.atomic.AtomicReference;
|
|||||||
import okhttp3.mockwebserver.MockResponse;
|
import okhttp3.mockwebserver.MockResponse;
|
||||||
import okhttp3.mockwebserver.MockWebServer;
|
import okhttp3.mockwebserver.MockWebServer;
|
||||||
import okio.BufferedSink;
|
import okio.BufferedSink;
|
||||||
import org.junit.After;
|
|
||||||
import org.junit.Rule;
|
import org.junit.Rule;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
|
|
||||||
@@ -39,9 +38,9 @@ public final class WholeOperationTimeoutTest {
|
|||||||
private static final String BIG_ENOUGH_BODY = TestUtil.repeat('a', 64 * 1024);
|
private static final String BIG_ENOUGH_BODY = TestUtil.repeat('a', 64 * 1024);
|
||||||
|
|
||||||
@Rule public final MockWebServer server = new MockWebServer();
|
@Rule public final MockWebServer server = new MockWebServer();
|
||||||
@Rule public final OkHttpClientTestingRule clientTestingRule = new OkHttpClientTestingRule();
|
@Rule public final OkHttpClientTestRule clientTestRule = new OkHttpClientTestRule();
|
||||||
|
|
||||||
private OkHttpClient client = clientTestingRule.client;
|
private OkHttpClient client = clientTestRule.client;
|
||||||
|
|
||||||
@Test public void defaultConfigIsNoTimeout() throws Exception {
|
@Test public void defaultConfigIsNoTimeout() throws Exception {
|
||||||
Request request = new Request.Builder()
|
Request request = new Request.Builder()
|
||||||
|
@@ -28,7 +28,7 @@ import okhttp3.DelegatingServerSocketFactory;
|
|||||||
import okhttp3.DelegatingSocketFactory;
|
import okhttp3.DelegatingSocketFactory;
|
||||||
import okhttp3.MediaType;
|
import okhttp3.MediaType;
|
||||||
import okhttp3.OkHttpClient;
|
import okhttp3.OkHttpClient;
|
||||||
import okhttp3.OkHttpClientTestingRule;
|
import okhttp3.OkHttpClientTestRule;
|
||||||
import okhttp3.Request;
|
import okhttp3.Request;
|
||||||
import okhttp3.RequestBody;
|
import okhttp3.RequestBody;
|
||||||
import okhttp3.Response;
|
import okhttp3.Response;
|
||||||
@@ -43,7 +43,7 @@ import org.junit.Test;
|
|||||||
import static org.junit.Assert.fail;
|
import static org.junit.Assert.fail;
|
||||||
|
|
||||||
public final class CancelTest {
|
public final class CancelTest {
|
||||||
@Rule public final OkHttpClientTestingRule clientTestingRule = new OkHttpClientTestingRule();
|
@Rule public final OkHttpClientTestRule clientTestRule = new OkHttpClientTestRule();
|
||||||
|
|
||||||
// The size of the socket buffers in bytes.
|
// The size of the socket buffers in bytes.
|
||||||
private static final int SOCKET_BUFFER_SIZE = 256 * 1024;
|
private static final int SOCKET_BUFFER_SIZE = 256 * 1024;
|
||||||
@@ -63,7 +63,7 @@ public final class CancelTest {
|
|||||||
return serverSocket;
|
return serverSocket;
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
client = clientTestingRule.client.newBuilder()
|
client = clientTestRule.client.newBuilder()
|
||||||
.socketFactory(new DelegatingSocketFactory(SocketFactory.getDefault()) {
|
.socketFactory(new DelegatingSocketFactory(SocketFactory.getDefault()) {
|
||||||
@Override protected Socket configureSocket(Socket socket) throws IOException {
|
@Override protected Socket configureSocket(Socket socket) throws IOException {
|
||||||
socket.setSendBufferSize(SOCKET_BUFFER_SIZE);
|
socket.setSendBufferSize(SOCKET_BUFFER_SIZE);
|
||||||
|
@@ -28,11 +28,10 @@ import okhttp3.DelegatingServerSocketFactory;
|
|||||||
import okhttp3.DelegatingSocketFactory;
|
import okhttp3.DelegatingSocketFactory;
|
||||||
import okhttp3.MediaType;
|
import okhttp3.MediaType;
|
||||||
import okhttp3.OkHttpClient;
|
import okhttp3.OkHttpClient;
|
||||||
import okhttp3.OkHttpClientTestingRule;
|
import okhttp3.OkHttpClientTestRule;
|
||||||
import okhttp3.Request;
|
import okhttp3.Request;
|
||||||
import okhttp3.RequestBody;
|
import okhttp3.RequestBody;
|
||||||
import okhttp3.Response;
|
import okhttp3.Response;
|
||||||
import okhttp3.TestUtil;
|
|
||||||
import okhttp3.mockwebserver.MockResponse;
|
import okhttp3.mockwebserver.MockResponse;
|
||||||
import okhttp3.mockwebserver.MockWebServer;
|
import okhttp3.mockwebserver.MockWebServer;
|
||||||
import okio.Buffer;
|
import okio.Buffer;
|
||||||
@@ -45,13 +44,13 @@ import org.junit.Test;
|
|||||||
import static org.junit.Assert.fail;
|
import static org.junit.Assert.fail;
|
||||||
|
|
||||||
public final class ThreadInterruptTest {
|
public final class ThreadInterruptTest {
|
||||||
@Rule public final OkHttpClientTestingRule clientTestingRule = new OkHttpClientTestingRule();
|
@Rule public final OkHttpClientTestRule clientTestRule = new OkHttpClientTestRule();
|
||||||
|
|
||||||
// The size of the socket buffers in bytes.
|
// The size of the socket buffers in bytes.
|
||||||
private static final int SOCKET_BUFFER_SIZE = 256 * 1024;
|
private static final int SOCKET_BUFFER_SIZE = 256 * 1024;
|
||||||
|
|
||||||
private MockWebServer server;
|
private MockWebServer server;
|
||||||
private OkHttpClient client = clientTestingRule.client;
|
private OkHttpClient client = clientTestRule.client;
|
||||||
|
|
||||||
@Before public void setUp() throws Exception {
|
@Before public void setUp() throws Exception {
|
||||||
// Sockets on some platforms can have large buffers that mean writes do not block when
|
// Sockets on some platforms can have large buffers that mean writes do not block when
|
||||||
@@ -66,7 +65,7 @@ public final class ThreadInterruptTest {
|
|||||||
return serverSocket;
|
return serverSocket;
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
client = clientTestingRule.client.newBuilder()
|
client = clientTestRule.client.newBuilder()
|
||||||
.socketFactory(new DelegatingSocketFactory(SocketFactory.getDefault()) {
|
.socketFactory(new DelegatingSocketFactory(SocketFactory.getDefault()) {
|
||||||
@Override
|
@Override
|
||||||
protected Socket configureSocket(Socket socket) throws IOException {
|
protected Socket configureSocket(Socket socket) throws IOException {
|
||||||
|
@@ -40,7 +40,7 @@ import okhttp3.Headers;
|
|||||||
import okhttp3.Interceptor;
|
import okhttp3.Interceptor;
|
||||||
import okhttp3.MediaType;
|
import okhttp3.MediaType;
|
||||||
import okhttp3.OkHttpClient;
|
import okhttp3.OkHttpClient;
|
||||||
import okhttp3.OkHttpClientTestingRule;
|
import okhttp3.OkHttpClientTestRule;
|
||||||
import okhttp3.Protocol;
|
import okhttp3.Protocol;
|
||||||
import okhttp3.RecordingCookieJar;
|
import okhttp3.RecordingCookieJar;
|
||||||
import okhttp3.RecordingHostnameVerifier;
|
import okhttp3.RecordingHostnameVerifier;
|
||||||
@@ -101,7 +101,7 @@ public final class HttpOverHttp2Test {
|
|||||||
|
|
||||||
@Rule public final TemporaryFolder tempDir = new TemporaryFolder();
|
@Rule public final TemporaryFolder tempDir = new TemporaryFolder();
|
||||||
@Rule public final MockWebServer server = new MockWebServer();
|
@Rule public final MockWebServer server = new MockWebServer();
|
||||||
@Rule public final OkHttpClientTestingRule clientTestingRule = new OkHttpClientTestingRule();
|
@Rule public final OkHttpClientTestRule clientTestRule = new OkHttpClientTestRule();
|
||||||
|
|
||||||
private OkHttpClient client;
|
private OkHttpClient client;
|
||||||
private Cache cache;
|
private Cache cache;
|
||||||
@@ -117,13 +117,13 @@ public final class HttpOverHttp2Test {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private OkHttpClient buildH2PriorKnowledgeClient() {
|
private OkHttpClient buildH2PriorKnowledgeClient() {
|
||||||
return clientTestingRule.client.newBuilder()
|
return clientTestRule.client.newBuilder()
|
||||||
.protocols(Arrays.asList(Protocol.H2_PRIOR_KNOWLEDGE))
|
.protocols(Arrays.asList(Protocol.H2_PRIOR_KNOWLEDGE))
|
||||||
.build();
|
.build();
|
||||||
}
|
}
|
||||||
|
|
||||||
private OkHttpClient buildHttp2Client() {
|
private OkHttpClient buildHttp2Client() {
|
||||||
return clientTestingRule.client.newBuilder()
|
return clientTestRule.client.newBuilder()
|
||||||
.protocols(Arrays.asList(Protocol.HTTP_2, Protocol.HTTP_1_1))
|
.protocols(Arrays.asList(Protocol.HTTP_2, Protocol.HTTP_1_1))
|
||||||
.sslSocketFactory(
|
.sslSocketFactory(
|
||||||
handshakeCertificates.sslSocketFactory(), handshakeCertificates.trustManager())
|
handshakeCertificates.sslSocketFactory(), handshakeCertificates.trustManager())
|
||||||
|
Reference in New Issue
Block a user