Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 169 for _producer (0.13 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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 3
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:12:26 GMT 2026
    - 4.6K bytes
    - Click Count (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. android/guava-testlib/src/com/google/common/testing/CollectorTester.java

            A result(Collector<T, A, R> collector, Iterable<T> inputs);
      }
    
      /**
       * Verifies that the specified expected result is always produced by collecting the specified
       * inputs, regardless of how the elements are divided.
       */
      @SafeVarargs
      @CanIgnoreReturnValue
    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)
  9. 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)
  10. 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 ENCRYPTION
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 10.9K bytes
    - Click Count (0)
Back to Top