- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 228 for ShutDown (0.06 sec)
-
okhttp/src/test/java/okhttp3/CallKotlinTest.kt
val proxySelector = RecordingProxySelector() proxySelector.proxies.add(Proxy(Proxy.Type.HTTP, TestUtil.UNREACHABLE_ADDRESS_IPV4)) proxySelector.proxies.add(Proxy.NO_PROXY) server.shutdown() client = client.newBuilder() .proxySelector(proxySelector) .readTimeout(Duration.ofMillis(100)) .connectTimeout(Duration.ofMillis(100)) .build()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 8.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
* that once the Thread returns to the Executor that this Executor composes, the interruption * will still be present. If the composed Executor is an ExecutorService, it can respond to * shutdown() by returning tasks queued on that Thread after {@link #worker} drains the queue. */ @SuppressWarnings("CatchingUnchecked") // sneaky checked exception private void workOnQueue() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 10.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/SequentialExecutor.java
* that once the Thread returns to the Executor that this Executor composes, the interruption * will still be present. If the composed Executor is an ExecutorService, it can respond to * shutdown() by returning tasks queued on that Thread after {@link #worker} drains the queue. */ @SuppressWarnings("CatchingUnchecked") // sneaky checked exception private void workOnQueue() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 10.6K bytes - Viewed (0) -
CHANGELOG.md
`LoggingEventListener.androidLogging()` write HTTP calls or events to Logcat. * New: `OkHttpClient.webSocketCloseTimeout` configures how long a web socket connection will wait for a graceful shutdown before it performs an abrupt shutdown. * Fix: Honor `RequestBody.isOneShot()` in `MultipartBody` * Fix in `okhttp-coroutines`: Don't leak response bodies in `executeAsync()`. We had a bug where
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 18 01:31:39 UTC 2024 - 21.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
reader.nextFrame(false, inFrame) inFrames.add(inFrame) } } } fun openSocket(): Socket = Socket("localhost", port) @Synchronized override fun close() { executor.shutdown() socket?.closeQuietly() serverSocket?.closeQuietly() } override fun toString(): String = "MockHttp2Peer[$port]" private class OutFrame( val sequence: Int, val start: Long,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 8.7K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
if (logger.isDebugEnabled()) { logger.debug("TimeoutManagerThread stopped."); } thread = null; try { executorService.shutdown(); executorService.awaitTermination(60, TimeUnit.SECONDS); } catch (final InterruptedException e) { if (logger.isDebugEnabled()) {
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 8K bytes - Viewed (0) -
src/test/java/jcifs/tests/WatchTest.java
this.base = createTestDirectory(); } @Override @After public void tearDown () throws Exception { if ( this.executor != null ) { this.executor.shutdown(); if ( this.future != null ) { this.future.cancel(true); } this.executor.awaitTermination(1, TimeUnit.SECONDS); } if ( this.base != null ) {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 8.4K bytes - Viewed (0) -
cmd/mrf.go
return } select { case m.opCh <- op: default: } } // Do not accept new MRF operations anymore and start to save // the current heal status in one available disk func (m *mrfState) shutdown() { atomic.StoreInt32(&m.closing, 1) m.wg.Wait() close(m.opCh) atomic.StoreInt32(&m.closed, 1) if len(m.opCh) > 0 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 6.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
} } return result } override fun peek(): MockResponse = queueDispatcher.peek() override fun shutdown() { queueDispatcher.shutdown() } } client = client.newBuilder() .proxy(server.toProxyAddress()) .build()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
cmd/logging.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 03 18:49:48 UTC 2024 - 7.1K bytes - Viewed (0)