- Sort Score
- Result 10 results
- Languages All
Results 551 - 560 of 1,049 for closes (0.06 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSocket.kt
delegate!!.sslParameters = p } @Throws(IOException::class) override fun close() { delegate!!.close() } override fun getInetAddress(): InetAddress = delegate!!.inetAddress @Throws(IOException::class) override fun getInputStream(): InputStream = delegate!!.inputStream @Throws(SocketException::class) override fun getKeepAlive(): Boolean = delegate!!.keepAlive
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 7.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
/** * OkHttp is usually tested with functional tests: these use public APIs to confirm behavior against * MockWebServer. In cases where logic is particularly tricky, we use unit tests. This class makes * it easy to get sample values to use in such tests. * * This class is pretty fast and loose with default values: it attempts to provide values that are
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri May 30 21:28:20 UTC 2025 - 7.7K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/Main.kt
builder.eventListenerFactory(LoggingEventListener.Factory(logger)) } return builder.build() } fun close() { val okHttpClient = client as OkHttpClient okHttpClient.connectionPool.evictAll() // Close any persistent connections. okHttpClient.dispatcher.executorService.shutdownNow() } companion object { internal const val NAME = "okcurl"
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 6K bytes - Viewed (0) -
mockwebserver-junit4/src/main/kotlin/mockwebserver3/junit4/MockWebServerRule.kt
* @JvmField @Rule val serverRule = MockWebServerRule() * ``` */ class MockWebServerRule : ExternalResource() { val server: MockWebServer = MockWebServer() override fun before() { try { server.start() } catch (e: IOException) { throw RuntimeException(e) } } override fun after() { server.close() }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jun 16 22:36:18 UTC 2025 - 1.4K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSource.kt
fun request(): Request /** * Immediately and violently release resources held by this event source. This does nothing if * the event source has already been closed or canceled. */ fun cancel() fun interface Factory { /** * Creates a new event source and immediately returns it. Creating an event source initiates an
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:47:47 UTC 2025 - 2.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java
logger.warn("Could not close a process input stream.", e); } }); CommonPoolUtil.execute(() -> { try { CloseableUtil.closeQuietly(p.getErrorStream()); } catch (final Exception e) { logger.warn("Could not close a process error stream.", e); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Fri Jul 18 14:34:06 UTC 2025 - 14.7K bytes - Viewed (0) -
src/test/java/jcifs/util/AuthenticationRateLimiterTest.java
import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import jcifs.smb.SmbException; /** * Test cases for AuthenticationRateLimiter */ public class AuthenticationRateLimiterTest { private AuthenticationRateLimiter rateLimiter; @BeforeEach public void setUp() { // Create rate limiter with test-friendly settings
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 15.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/IoTestCase.java
import org.jspecify.annotations.NullUnmarked; import org.jspecify.annotations.Nullable; /** * Base test case class for I/O tests. * * @author Chris Nokleberg * @author Colin Decker */ @NullUnmarked public abstract class IoTestCase extends TestCase { private static final Logger logger = Logger.getLogger(IoTestCase.class.getName()); static final String I18N = "\u00CE\u00F1\u0163\u00E9\u0072\u00F1\u00E5\u0163\u00EE\u00F6"
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 5.6K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/msrpc/SamrPolicyHandle.java
import jcifs.dcerpc.rpc; import jcifs.smb.SmbException; /** * Handle for Security Account Manager (SAM) policy operations. * This class represents an open handle to a SAM server and provides * high-level access to SAM database operations. */ public class SamrPolicyHandle extends rpc.policy_handle implements AutoCloseable { private final DcerpcHandle handle; private boolean opened; /**
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/FileBackedOutputStreamAndroidIncompatibleTest.java
write(out, data, 0, 100, true); File file = out.getFile(); assertEquals(100, file.length()); assertTrue(file.exists()); out.close(); // Make sure that finalize deletes the file out = null; // times out and throws RuntimeException on failure GcFinalization.awaitDone( new GcFinalization.FinalizationPredicate() { @Override public boolean isDone() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 1.7K bytes - Viewed (0)