- Sort Score
- Num 10 results
- Language All
Results 131 - 140 of 550 for takeIf (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/event/target/kafka_scram_client_contrib.go
x.Client, err = x.NewClient(userName, password, authzID) if err != nil { return err } x.ClientConversation = x.NewConversation() return nil } // Step takes a string provided from a server (or just an empty string for the // very first conversation step) and attempts to move the authentication // conversation forward. It returns a string to be sent to the server or an
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 3.2K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ForwardingBlockingDeque.java
@Override public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException { return delegate().offer(e, timeout, unit); } @Override public E take() throws InterruptedException { return delegate().take(); } @Override public @Nullable E poll(long timeout, TimeUnit unit) throws InterruptedException { return delegate().poll(timeout, unit); } @Override
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 4.3K bytes - Click Count (0) -
docs/distributed/SIZING.md
protection bits added automatically to provide the regular safety for these objects up to 50% of the number of drives. This will allow normal write operations to take place on systems that exceed the write tolerance.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 15 23:04:20 GMT 2023 - 3.9K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/SingleThreadAbstractFutureBenchmark.java
import java.util.concurrent.CancellationException; import java.util.concurrent.ExecutionException; import java.util.concurrent.TimeoutException; import org.jspecify.annotations.NullUnmarked; /** A benchmark that times how long it takes to add a given number of */ @VmOptions({"-Xms8g", "-Xmx8g"}) @NullUnmarked public class SingleThreadAbstractFutureBenchmark { @Param Impl impl; private final Exception exception = new Exception();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 3.7K bytes - Click Count (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/interpolation/ObjectBasedValueSource.java
* accessor types to resolve the value for each successive expression part. * Finally, return the result of the last expression part's resolution.</p> * * <p><b>NOTE:</b> The object-graph navigation actually takes place via the * {@link ReflectionValueExtractor} class.</p> */ @Override public Object getValue(String expression) { if (expression == null || expression.trim().isEmpty()) {Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 3.4K bytes - Click Count (0) -
internal/logger/target/kafka/kafka_scram_client_contrib.go
x.Client, err = x.NewClient(userName, password, authzID) if err != nil { return err } x.ClientConversation = x.NewConversation() return nil } // Step takes a string provided from a server (or just an empty string for the // very first conversation step) and attempts to move the authentication // conversation forward. It returns a string to be sent to the server or an
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 3.3K bytes - Click Count (0) -
CONTRIBUTING.md
We may ask you to answer these questions directly in the GitHub issue or (for large changes) in a shared Google Doc. Please note that some features may be out of the team's current focus, and it can take significant time for the team to review the PR thoroughly and address it fully. ### Security vulnerabilities
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Fri Mar 27 18:43:39 GMT 2026 - 19.1K bytes - Click Count (0) -
guava-testlib/src/com/google/common/testing/GcFinalization.java
import org.jspecify.annotations.NullMarked; /** * Testing utilities relating to garbage collection finalization. * * <p>Use this class to test code triggered by finalization, that is, one of the following * actions taken by the java garbage collection system: * * <ul> * <li>invoking the {@code finalize} methods of unreachable objects * <li>clearing weak references to unreachable referents
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 20:19:19 GMT 2026 - 12.3K bytes - Click Count (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/interpolation/reflection/MethodMap.java
* primitive type arguments are represented by * their object counterparts, so for an argument of * type (say) java.lang.Integer, it will not be able * to decide between a method that takes int and a * method that takes java.lang.Integer as a parameter. * <p> * This turns out to be a relatively rare case * where this is needed - however, functionality * like this is needed. *Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Tue Feb 25 08:27:34 GMT 2025 - 14.2K bytes - Click Count (0) -
guava/src/com/google/common/base/CaseFormat.java
this.wordSeparator = wordSeparator; } /** * Converts the specified {@code String str} from this format to the specified {@code format}. A * "best effort" approach is taken; if {@code str} does not conform to the assumed format, then * the behavior of this method is undefined but we make a reasonable effort at converting anyway. */ public final String to(CaseFormat format, String str) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Dec 03 18:46:33 GMT 2025 - 6.5K bytes - Click Count (0)