- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 701 for seconden (0.08 sec)
-
src/main/java/org/codelibs/core/misc/Pair.java
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Sat May 10 01:32:17 UTC 2025 - 3.5K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/AbstractCrawlerClient.java
/** The maximum cached content size in bytes. Default is 1MB. */ protected long maxCachedContentSize = 1024L * 1024L; // 1MB /** The access timeout in seconds. Default is null (no timeout). */ protected Integer accessTimeout = null; // seconds /** The maximum content length in bytes. Default is null (no limit). */ protected Long maxContentLength = null; /**
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 9.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/PopulatedCachesTest.java
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 15.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
exec.execute(task); runLatch.await(); taskLatch.countDown(); ExecutionException e = assertThrows(ExecutionException.class, () -> task.get(5, SECONDS)); assertEquals(IllegalStateException.class, e.getCause().getClass()); assertTrue(listenerLatch.await(5, SECONDS)); assertTrue(task.isDone()); assertFalse(task.isCancelled()); } public void testListenerCalledOnCancelFromNotRunning() throws Exception {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 4.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java
"foo", getChecked(immediateFuture("foo"), TwoArgConstructorException.class, 0, SECONDS)); } public void testGetCheckedTimed_interrupted() { SettableFuture<String> future = SettableFuture.create(); Thread.currentThread().interrupt(); try { getChecked(future, TwoArgConstructorException.class, 0, SECONDS); fail(); } catch (TwoArgConstructorException expected) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 16.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CacheControlTest.kt
@Test @Throws(Exception::class) fun completeBuilder() { val cacheControl = CacheControl .Builder() .noCache() .noStore() .maxAge(1.seconds) .maxStale(2.seconds) .minFresh(3.seconds) .onlyIfCached() .noTransform() .immutable() .build() assertThat(cacheControl.toString()).isEqualTo(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 2.7K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/suggest/concurrent/DeferredTest.java
}); th.start(); final CountDownLatch latch = new CountDownLatch(1); deferred.promise().then(response -> latch.countDown()); assertTrue(latch.await(10, TimeUnit.SECONDS)); } @Test public void test_doneAfterResolve() throws Exception { final Deferred<SuggestResponse> deferred = new Deferred<>(); Thread th = new Thread(() -> {
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Sat Mar 15 06:51:20 UTC 2025 - 4.8K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
import static java.util.concurrent.Executors.newCachedThreadPool; import static java.util.concurrent.Executors.newSingleThreadExecutor; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static java.util.concurrent.TimeUnit.SECONDS; import static org.junit.Assert.assertThrows; import com.google.common.annotations.GwtIncompatible; import com.google.common.util.concurrent.ListenableFuture; import java.util.concurrent.CancellationException;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 6.1K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/SocketChannelTest.kt
} val client = clientTestRule .newClientBuilder() .dns { listOf(InetAddress.getByName("localhost")) } .callTimeout(4, SECONDS) .writeTimeout(2, SECONDS) .readTimeout(2, SECONDS) .apply { if (socketMode is TlsInstance) { if (socketMode.socketMode == Channel) { socketFactory(ChannelSocketFactory()) }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java
mock.assertLastMethodCalled("scheduleRunnable", 10, MINUTES); Future<?> unused2 = testExecutor.schedule(callable(DO_NOTHING), 5, SECONDS); mock.assertLastMethodCalled("scheduleCallable", 5, SECONDS); } public void testSchedule_repeating() { MockExecutor mock = new MockExecutor(); TestExecutor testExecutor = new TestExecutor(mock);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Jul 14 14:44:08 UTC 2025 - 7.4K bytes - Viewed (0)