- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 146 for producer (0.06 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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 3Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:33:45 GMT 2026 - 4.9K 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/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) -
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)