- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 169 for _producer (0.13 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
api/maven-api-core/src/main/java/org/apache/maven/api/Packaging.java
import org.apache.maven.api.model.PluginContainer; /** * Represents the packaging of a Maven project. * * <p>The {@code Packaging} class defines the type of artifact that a Maven project produces during the build process. * The packaging type determines the structure of the project's output and how Maven will treat the resulting artifact.</p> *Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 3.2K bytes - Click Count (0) -
src/test/java/jcifs/smb1/util/HMACT64Test.java
different = true; break; } } assertEquals(true, different, "Different keys should produce different HMAC values"); } @Test void testDifferentDataProducesDifferentResults() { // Test that different data produces different results byte[] data1 = "data1".getBytes(); byte[] data2 = "data2".getBytes();Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 10.1K bytes - Click Count (0) -
docs/es/docs/tutorial/stream-json-lines.md
```mermaid sequenceDiagram participant App participant Client App->>App: Produce Item 1 App->>Client: Send Item 1 App->>App: Produce Item 2 Client->>Client: Process Item 1 App->>Client: Send Item 2 App->>App: Produce Item 3 Client->>Client: Process Item 2 App->>Client: Send Item 3 Client->>Client: Process Item 3Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:12:26 GMT 2026 - 4.6K 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) -
src/main/java/org/codelibs/fess/suggest/request/Request.java
import org.opensearch.core.common.Strings; import org.opensearch.transport.client.Client; /** * Abstract class representing a request that can be executed to produce a response. * * @param <T> the type of response produced by this request */ public abstract class Request<T extends Response> { /** * Constructs a new request. */ public Request() { // nothing }
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sun Nov 23 11:21:40 GMT 2025 - 2.3K bytes - Click Count (0) -
internal/logger/target/kafka/kafka.go
// refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355 sconfig.Producer.Retry.Max = 2 sconfig.Producer.Retry.Backoff = (10 * time.Second) sconfig.Producer.Return.Successes = true sconfig.Producer.Return.Errors = true sconfig.Producer.RequiredAcks = 1 sconfig.Producer.Timeout = (10 * time.Second) sconfig.Net.ReadTimeout = (10 * time.Second) sconfig.Net.DialTimeout = (10 * time.Second)
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) -
guava-tests/test/com/google/common/collect/QueuesTest.java
assertEquals(0, Queues.drain(q, ImmutableList.of(), 1, 10, MILLISECONDS)); Producer producer = new Producer(q, 1); // producing one, will ask for two Future<?> producerThread = threadPool.submit(producer); producer.beganProducing.await(); // make sure we time out Stopwatch timer = Stopwatch.createStarted();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Nov 04 17:24:58 GMT 2025 - 12.6K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/testing/CollectorTester.java
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 16 22:01:32 GMT 2025 - 6.8K bytes - Click Count (0) -
src/test/java/jcifs/smb/DirFileEntryEnumIterator2Test.java
DirFileEntryEnumIterator2 it = new DirFileEntryEnumIterator2(tree, parent, "*", null, 0); // Assert: enumeration is empty and close produced no extra close call (no fileId opened) assertFalse(it.hasNext(), "Empty listing should produce no elements"); it.close(); // No close should be sent because directory was never successfully opened
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 13.7K bytes - Click Count (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
// Consuming ECDH ServerKeyExchange handshake message // Consuming ServerHelloDone handshake message // Produced ECDHE ClientKeyExchange handshake message // Produced client Finished handshake message // Consuming server Finished handshake message // Produced ClientHello handshake message // // Raw write // Raw read // Plaintext before ENCRYPTIONCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 10.9K bytes - Click Count (0)