- Sort Score
- Num 10 results
- Language All
Results 421 - 430 of 1,779 for throwIf (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
android/guava/src/com/google/common/graph/BaseGraph.java
* {@code view} returned by this method will be invalidated, and will throw {@code * IllegalStateException} if it is accessed in any way, with the following exceptions: * * <ul> * <li>{@code view.equals(view)} evaluates to {@code true} (but any other {@code equals(...)} * expression involving {@code view} will throw) * <li>{@code hashCode()} does not throwCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Nov 11 17:11:16 GMT 2025 - 2.9K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java
} } /** * Checks if the executor has been shut down and increments the running task count. * * @throws RejectedExecutionException if the executor has been previously shutdown */ private void startTask() { synchronized (lock) { if (shutdown) { throw new RejectedExecutionException("Executor already shutdown"); } runningTasks++; } }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Dec 16 14:23:59 GMT 2025 - 3.4K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessCurtainBeforeHookTest.java
@Override protected void setUp(TestInfo testInfo) throws Exception { super.setUp(testInfo); curtainBeforeHook = new FessCurtainBeforeHook(); // Store original timezone settings originalTimeZone = TimeZone.getDefault(); originalProvider = getDBFluteSystemTimeZoneProvider(); } @Override protected void tearDown(TestInfo testInfo) throws Exception { // Restore original timezone settingsCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 8.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/CrawlingInfoHelper.java
* * @param sessionId the session ID for the crawling information * @param create if true, creates a new crawling info regardless of existing records * @throws FessSystemException if unable to store the crawling session */ public synchronized void store(final String sessionId, final boolean create) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 15.2K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/entity/QueryContextTest.java
import org.opensearch.search.sort.SortBuilders; public class QueryContextTest extends UnitFessTestCase { private QueryContext queryContext; @Override protected void setUp(TestInfo testInfo) throws Exception { super.setUp(testInfo); // Set up FessConfig mock ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() { private static final long serialVersionUID = 1L;Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 17.6K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/dict/DictionaryExpiredExceptionTest.java
try { throw new DictionaryExpiredException(); } catch (RuntimeException e) { assertNotNull(e); assertTrue(e instanceof DictionaryExpiredException); } catch (Exception e) { fail("Should have caught as RuntimeException"); } } @Test public void test_serialization() throws Exception {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 7.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
assertThat(logHandler.getStoredLogRecords().get(0).getMessage()) .isEqualTo("Exception while executing callback: MyListener custom-label"); } public void testEnqueueAndDispatch_multithreaded() throws InterruptedException { Object listener = new Object(); ExecutorService service = newFixedThreadPool(4); ListenerCallQueue<Object> queue = new ListenerCallQueue<>(); try {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 8.4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
assertThat(logHandler.getStoredLogRecords().get(0).getMessage()) .isEqualTo("Exception while executing callback: MyListener custom-label"); } public void testEnqueueAndDispatch_multithreaded() throws InterruptedException { Object listener = new Object(); ExecutorService service = newFixedThreadPool(4); ListenerCallQueue<Object> queue = new ListenerCallQueue<>(); try {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 8.4K bytes - Click Count (0) -
src/main/java/org/codelibs/core/zip/ZipFileUtil.java
return FileUtil.getCanonicalPath(zipFile); } /** * Closes the Zip file. * <p> * If {@link ZipFile#close()} throws an exception, an error message is logged. The exception is not rethrown. * </p> * * @param zipFile * Zip file. Must not be {@literal null}. */
Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Thu Jul 31 08:16:49 GMT 2025 - 4.7K bytes - Click Count (0) -
guava-gwt/test-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/TestPlatform.java
static <V extends @Nullable Object> V getDoneFromTimeoutOverload(Future<V> future) throws ExecutionException { checkState(future.isDone(), "Future was expected to be done: %s", future); try { return future.get(0, SECONDS); } catch (InterruptedException e) { throw new AssertionError(); } catch (TimeoutException e) { throw new AssertionError(); } } private TestPlatform() {}
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 2.3K bytes - Click Count (0)