- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 32 for Producers (0.38 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* automate the process, often adding features like monitoring, debugging, and cancellation. * Examples of frameworks include: * * <ul> * <li><a href="https://dagger.dev/producers.html">Dagger Producers</a> * </ul> * * <p>The main purpose of {@link #addListener addListener} is to support this chaining. You will * rarely use it directly, in part because it does not provide direct access to the {@code Future}
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 22:14:05 GMT 2026 - 8K bytes - Click Count (0) -
internal/event/target/nsq.go
} return target.isActive() } func (target *NSQTarget) isActive() (bool, error) { if target.producer == nil { producer, err := nsq.NewProducer(target.args.NSQDAddress.String(), target.config) if err != nil { return false, err } target.producer = producer } if err := target.producer.Ping(); err != nil { // To treat "connection refused" errors as errNotConnected. if xnet.IsConnRefusedErr(err) {
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) -
build-tools-internal/src/integTest/groovy/org/elasticsearch/gradle/internal/InternalDistributionArchiveSetupPluginFuncTest.groovy
file("producer-tar/build/install/someFile.txt").exists() file("producer-tar/build/install/snapshot-1.0.txt").exists() file("consumer/build/dir/someFile.txt").exists() when: gradleRunner("copyDir", "-Pversion=2.0").build() then: "old content is cleared out" file("producer-tar/build/install/someFile.txt").exists()
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 8.4K bytes - Click Count (0) -
.github/ISSUE_TEMPLATE/tflite-converter-issue.md
``` ### 3. Failure after conversion If the conversion is successful, but the generated model is wrong, then state what is wrong: - Model produces wrong results and/or has lesser accuracy. - Model produces correct results, but it is slower than expected. ### 4. (optional) RNN conversion support If converting TF RNN to TFLite fused RNN ops, please prefix [RNN] in the title.
Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Wed Jun 15 03:35:58 GMT 2022 - 2.1K bytes - Click Count (0) -
src/test/java/jcifs/util/CryptoTest.java
// When MessageDigest md4 = Crypto.getMD4(); byte[] hash = md4.digest(data); // Then assertNotNull(hash); assertEquals(16, hash.length); // MD4 produces 128-bit hash } @Test @DisplayName("Should calculate MD5 hash correctly") void testMD5Hash() { // Given String input = "Hello World"; byte[] data = input.getBytes();Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 7.4K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/conflict/ConflictResolverFactory.java
* specific language governing permissions and limitations * under the License. */ package org.apache.maven.repository.legacy.resolver.conflict; /** * A factory that produces conflict resolvers of various types. * * @see ConflictResolver * @since 3.0 */ @Deprecated public interface ConflictResolverFactory {Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 1.6K bytes - Click Count (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/filters/KotlinInvokeDefaultBridgeFilter.groovy
* limitations under the License. */ package gradlebuild.binarycompatibility.filters import japicmp.filter.BehaviorFilter import javassist.CtBehavior /** * Kotlin 2.2 produces bridge methods for invoke operator functions compiled as JVM default methods. */ class KotlinInvokeDefaultBridgeFilter implements BehaviorFilter { @Override boolean matches(CtBehavior ctBehavior) {Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Tue Jul 08 07:03:16 GMT 2025 - 1K bytes - Click Count (0) -
guava-gwt/src-super/com/google/common/base/super/com/google/common/base/Platform.java
import org.jspecify.annotations.Nullable; /** * @author Jesse Wilson */ final class Platform { static CharMatcher precomputeCharMatcher(CharMatcher matcher) { // CharMatcher.precomputed() produces CharMatchers that are maybe a little // faster (and that's debatable), but definitely more memory-hungry. We're // choosing to turn .precomputed() into a no-op in GWT, because it doesn'tCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 03 21:52:39 GMT 2025 - 2.2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/crawler/helper/FessMimeTypeHelper.java
* FessMimeTypeHelper extends MimeTypeHelperImpl to provide Fess-specific * MIME type detection configuration. It reads extension-to-MIME-type override * mappings from FessConfig to handle cases where content-based detection * produces incorrect results (e.g., SQL files starting with REM comments * being misdetected as batch files). */ public class FessMimeTypeHelper extends MimeTypeHelperImpl {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Jan 24 09:06:33 GMT 2026 - 2.7K bytes - Click Count (0) -
guava-tests/benchmark/com/google/common/hash/HashCodeBenchmark.java
* <li>equalsImpl: which implementation of array equality to use * </ul> * * <p><b>Important note:</b> the primary goal of this benchmark is to ensure that varying {@code * whereToDiffer} produces no observable change in performance. We want to make sure that the array * equals implementation is *not* short-circuiting to prevent timing-based attacks. Being fast is * only a secondary goal. *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Aug 11 19:31:30 GMT 2025 - 4K bytes - Click Count (0)