- Sort Score
- Num 10 results
- Language All
Results 391 - 400 of 3,597 for will (0.52 seconds)
-
internal/event/target/nsq.go
_, err := target.isActive() if err != nil { return err } eventData, eErr := target.store.Get(key) if eErr != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(eErr) { return nil } return eErr } if err := target.send(eventData); err != nil {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 7.1K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/graph/FilteredProjectDependencyGraph.java
// only A, C, and E are whitelisted duplicates will occur. When scanning projects A, C, and E, those will be // added to 'filtered' as they are whitelisted. When scanning B and D, they are not whitelisted, and since // transitive is false, their downstream dependencies will be added to 'filtered'. E is a downstream dependency // of A, B, C, and D, so when scanning B and D, E will be added again 'filtered'. //Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Jun 19 16:34:39 GMT 2025 - 6.4K bytes - Click Count (0) -
internal/logger/target/kafka/kafka.go
// stop the replay go-routine. if h.store != nil { h.storeCtxCancel() } // Set logch to nil and close it. // This will block all Send operations, // and finish the existing ones. // All future ones will be discarded. h.logChMu.Lock() xioutil.SafeClose(h.logCh) h.logCh = nil h.logChMu.Unlock() if h.producer != nil { h.producer.Close()Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 10.2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueClassLoaderUnloadingTest.java
// sepLoader is the loader that we will use to load the parallel FinalizableReferenceQueue (FRQ) // and friends, and that we will eventually expect to see garbage-collected. The assumption // is that the ClassLoader of this test is a URLClassLoader, and that it loads FRQ itself // rather than delegating to a parent ClassLoader. If this assumption is violated the test will // fail and will need to be rewritten.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Feb 26 02:41:17 GMT 2026 - 7.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/FallbackTestClientSocketFactory.kt
/** * An SSLSocketFactory that delegates calls. Sockets created by the delegate are wrapped with ones * that will not accept the [TLS_FALLBACK_SCSV] cipher, thus bypassing server-side fallback * checks on platforms that support it. Unfortunately this wrapping will disable any * reflection-based calls to SSLSocket from Platform. */ class FallbackTestClientSocketFactory( delegate: SSLSocketFactory,
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 2K bytes - Click Count (0) -
docs/contribute/concurrency.md
manage network connections. Creating and establishing new connections require a fair amount of overhead and added latency. OkHttp will make every effort to reuse existing connections to avoid this overhead and added latency. Every OkHttpClient uses a connection pool. Its job is to maintain a reference to all open connections. When an HTTP request is started, OkHttp will attempt to reuse an existing connection from the pool. If there are no existing connections, a new one is created and put into...
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 7K bytes - Click Count (0) -
src/main/java/org/codelibs/core/beans/util/CopyOptions.java
return this; } /** * Specifies the prefix. * <p> * When a prefix is specified, only properties whose names start with the prefix will be included in the copy operation. * Additionally, the prefix will be removed from the source property name to form the destination property name. * </p> * * @param prefixCreated: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Sat Jul 05 00:11:05 GMT 2025 - 17.5K bytes - Click Count (0) -
api/maven-api-spi/src/main/java/org/apache/maven/api/spi/LifecycleProvider.java
* of phases that can be executed during a build. * <p> * Implementations of this interface will be discovered through the Java ServiceLoader mechanism * and their provided lifecycles will be available throughout the Maven build process. * <p> * Example usage: * <pre> * public class CustomLifecycleProvider implements LifecycleProvider {
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Apr 03 13:33:59 GMT 2025 - 2.2K bytes - Click Count (0) -
api/maven-api-spi/src/main/java/org/apache/maven/api/spi/PathScopeProvider.java
* in different contexts, such as compilation, testing, or runtime. * <p> * Implementations of this interface will be discovered through the Java ServiceLoader mechanism * and their provided path scopes will be available throughout the Maven build process. * <p> * Example usage: * <pre> * public class CustomPathScopeProvider implements PathScopeProvider {
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Apr 03 13:33:59 GMT 2025 - 2.1K bytes - Click Count (0) -
api/maven-api-spi/src/main/java/org/apache/maven/api/spi/TypeProvider.java
* are handled, including their default extension, classifier, and language. * <p> * Implementations of this interface will be discovered through the Java ServiceLoader mechanism * and their provided types will be available throughout the Maven build process. * <p> * Example usage: * <pre> * public class CustomTypeProvider implements TypeProvider {
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Apr 03 13:33:59 GMT 2025 - 2.1K bytes - Click Count (0)