- Sort Score
- Num 10 results
- Language All
Results 2501 - 2510 of 2,922 for throwIf (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
benchmarks/src/main/java/org/elasticsearch/benchmark/routing/allocation/Allocators.java
RoutingAllocation allocation, UnassignedAllocationHandler unassignedAllocationHandler ) { // noop } } private Allocators() { throw new AssertionError("Do not instantiate"); } public static AllocationService createAllocationService(Settings settings) {Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Wed Feb 03 00:10:53 GMT 2021 - 3.9K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/builder/multithreaded/MultiThreadedBuilder.java
ReactorContext reactorContext, ProjectBuildList projectBuilds, List<TaskSegment> taskSegments, ReactorBuildStatus reactorBuildStatus) throws ExecutionException, InterruptedException { int nThreads = Math.min( session.getRequest().getDegreeOfConcurrency(), session.getProjects().size()); boolean parallel = nThreads > 1;Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Wed Jul 16 03:42:09 GMT 2025 - 8.9K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/collect/testing/ReserializingTestCollectionGenerator.java
out.writeObject(object); ObjectInputStream in = new ObjectInputStream(new ByteArrayInputStream(bytes.toByteArray())); return (T) in.readObject(); } catch (IOException | ClassNotFoundException e) { throw new AssertionError(e); } } @Override public SampleElements<E> samples() { return delegate.samples(); } @Override public E[] createArray(int length) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Jun 11 16:13:05 GMT 2024 - 2.4K bytes - Click Count (0) -
android/guava/src/com/google/common/io/RecursiveDeleteOption.java
* @author Colin Decker */ @J2ktIncompatible @GwtIncompatible @J2ObjCIncompatible // java.nio.file public enum RecursiveDeleteOption { /** * Specifies that the recursive delete should not throw an exception when it can't be guaranteed * that it can be done securely, without vulnerability to race conditions (i.e. when the file * system does not support {@link SecureDirectoryStream}). *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 2K bytes - Click Count (0) -
guava-tests/test/com/google/common/reflect/AbstractInvocationHandlerTest.java
DelegatingInvocationHandler(Object delegate) { this.delegate = checkNotNull(delegate); } @Override protected Object handleInvocation(Object proxy, Method method, Object[] args) throws Throwable { return method.invoke(delegate, args); } @Override public String toString() { return "some arbitrary string"; } }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 5.8K bytes - Click Count (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/building/ModelProblem.java
* under the License. */ package org.apache.maven.model.building; /** * Describes a problem that was encountered during model building. A problem can either be an exception that was thrown * or a simple string message. In addition, a problem carries a hint about its source, e.g. the POM file that exhibits * the problem. * * @deprecated use {@code org.apache.maven.api.services.ModelBuilder} instead */Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Tue Feb 25 08:27:34 GMT 2025 - 4K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/entity/FacetQueryViewTest.java
private TestFacetInfo testFacetInfo; private TestFileTypeHelper testFileTypeHelper; private TestFessConfig testFessConfig; @Override protected void setUp(TestInfo testInfo) throws Exception { super.setUp(testInfo); facetQueryView = new FacetQueryView(); testFacetInfo = new TestFacetInfo(); testFileTypeHelper = new TestFileTypeHelper();Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 17.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt
val address: Address /** Follow-ups for failed plans and plans that lost a race. */ val deferredPlans: ArrayDeque<Plan> fun isCanceled(): Boolean /** Returns a plan to attempt. */ @Throws(IOException::class) fun plan(): Plan /** * Returns true if there's more route plans to try. * * @param failedConnection an optional connection that was resulted in a failure. If the failure
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue May 27 14:58:02 GMT 2025 - 4.2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java
coordinator.completeOperation("reload_doc_index"); })); }); } catch (final Exception e) { coordinator.completeOperation("reload_doc_index"); throw e; } saveInfo(messages -> messages.addSuccessStartedDataUpdate(GLOBAL)); return redirect(getClass()); } /**
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 23K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/CartesianList.java
try { for (int i = axes.size() - 1; i >= 0; i--) { axesSizeProduct[i] = Math.multiplyExact(axesSizeProduct[i + 1], axes.get(i).size()); } } catch (ArithmeticException e) { throw new IllegalArgumentException( "Cartesian product too large; must have size at most Integer.MAX_VALUE"); } this.axesSizeProduct = axesSizeProduct; }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Aug 31 13:15:26 GMT 2025 - 4.7K bytes - Click Count (0)