- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 247 for InterruptedException (0.07 sec)
-
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/QueueDispatcher.kt
* limitations under the License. */ package okhttp3.mockwebserver import mockwebserver3.QueueDispatcher class QueueDispatcher : Dispatcher() { internal val delegate = QueueDispatcher() @Throws(InterruptedException::class) override fun dispatch(request: RecordedRequest): MockResponse = throw UnsupportedOperationException("unexpected call") override fun peek(): MockResponse = throw UnsupportedOperationException("unexpected call")
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 14 16:09:26 UTC 2025 - 1.3K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/ftp/FtpClientTest.java
@Override protected ResponseData getResponseData(final String uri, final boolean includeContent) { try { Thread.sleep(2000); } catch (InterruptedException e) { throw new CrawlingAccessException(e); } return null; } }; client.setAccessTimeout(1); try {
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 18K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/duplex/AsyncRequestBody.kt
override fun contentType(): MediaType? = null override fun writeTo(sink: BufferedSink) { requestBodySinks.add(sink) } override fun isDuplex(): Boolean = true @Throws(InterruptedException::class) fun takeSink(): BufferedSink = requestBodySinks.poll(5, SECONDS) ?: throw AssertionError("no sink to take") fun assertNoMoreSinks() { assertTrue(requestBodySinks.isEmpty()) }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 1.5K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/Smb2SigningDigestTest.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 43.7K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/IntervalControlHelperTest.java
cal.set(Calendar.DAY_OF_WEEK, day); return cal; } }; } public void test_checkCrawlerStatus() throws InterruptedException { IntervalControlHelper helper = new IntervalControlHelper(); helper.setCrawlerWaitMillis(50); // Test when crawler is running assertTrue(helper.isCrawlerRunning());
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 10 13:41:04 UTC 2025 - 13.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
assertFalse(shutDownCalled); runCalled = true; assertEquals(State.RUNNING, state()); enterRun.countDown(); try { exitRun.await(); } catch (InterruptedException e) { throw new RuntimeException(e); } } @Override protected void shutDown() { assertTrue(startUpCalled); assertTrue(runCalled);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 12.8K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/Dispatcher.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.mockwebserver abstract class Dispatcher { @Throws(InterruptedException::class) abstract fun dispatch(request: RecordedRequest): MockResponse open fun peek(): MockResponse = MockResponse().apply { this.socketPolicy = SocketPolicy.KEEP_OPEN } open fun shutdown() {}
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 894 bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionCoalescingTest.kt
proxy: Proxy, ) { try { // Wait for request2 to guarantee we make 2 separate connections to the server. latch1.await() } catch (e: InterruptedException) { throw AssertionError(e) } } override fun connectionAcquired( call: Call, connection: Connection, ) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jun 19 11:44:16 UTC 2025 - 19.1K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/lease/DirectoryCacheEntryTest.java
assertFalse(entry.isExpired()); assertFalse(entry.needsRefresh()); // Wait for expiration try { Thread.sleep(150); } catch (InterruptedException e) { // Ignore } assertTrue(entry.isExpired()); assertTrue(entry.needsRefresh()); } @Test public void testNeedsRefresh() {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 01:47:47 UTC 2025 - 8.4K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/multichannel/ChannelInfoTest.java
@Test void testActivityTracking() { long initialTime = channelInfo.getLastActivityTime(); // Wait a bit and update activity try { Thread.sleep(10); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } channelInfo.updateActivity(); assertTrue(channelInfo.getLastActivityTime() > initialTime);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 7.4K bytes - Viewed (0)