Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 146 for producer (0.07 seconds)

  1. 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)
  2. 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)
  3. src/test/java/jcifs/smb/WinErrorTest.java

            for (int i = 0; i < codes.length; i++) {
                if (codes[i] == code) {
                    return Optional.of(msgs[i]);
                }
            }
            return Optional.empty();
        }
    
        // Producer for code->message pairs covering all known constants (happy path)
        static Stream<Arguments> knownCodeMessagePairs() {
            return Stream.of(Arguments.of(WinError.ERROR_SUCCESS, "The operation completed successfully."),
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  4. 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)
  5. 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)
  6. tests/test_request_body_parameters_media_type.py

    
    # NOTE: These are not valid JSON:API resources
    # but they are fine for testing requestBody with custom media_type
    class Product(BaseModel):
        name: str
        price: float
    
    
    class Shop(BaseModel):
        name: str
    
    
    @app.post("/products")
    async def create_product(data: Product = Body(media_type=media_type, embed=True)):
        pass  # pragma: no cover
    
    
    @app.post("/shops")
    async def create_shop(
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Feb 08 10:18:38 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  7. docs/fr/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
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:33:45 GMT 2026
    - 4.9K bytes
    - Click Count (0)
  8. 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)
  9. src/test/java/jcifs/smb1/smb1/NtlmChallengeTest.java

                assertNull(nc.dc);
            }
        }
    
        @Nested
        @DisplayName("toString() Tests")
        class ToStringTests {
    
            @Test
            @DisplayName("toString with valid data produces expected format")
            void testToStringWithValidData() {
                byte[] challenge = new byte[] { (byte) 0x01, (byte) 0x02, (byte) 0x03, (byte) 0xFF };
                UniAddress dc = mock(UniAddress.class);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 6K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/hash/PrimitiveSink.java

       *
       * <p><b>Warning:</b> This method, which reencodes the input before processing it, is useful only
       * for cross-language compatibility. For other use cases, prefer {@link #putUnencodedChars}, which
       * is faster, produces the same output across Java releases, and processes every {@code char} in
       * the input, even if some are invalid.
       */
      @CanIgnoreReturnValue
      PrimitiveSink putString(CharSequence charSequence, Charset charset);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 3.9K bytes
    - Click Count (0)
Back to Top