- Sort Score
- Num 10 results
- Language All
Results 971 - 980 of 1,059 for Streams (0.12 seconds)
-
src/cmd/asm/internal/lex/input.go
prevCol := in.Stack.Col() tok := in.Stack.Next() if tok == '\n' || tok == scanner.EOF { return nil, nil // No definition for macro } var args []string // The C preprocessor treats // #define A(x) // and // #define A (x) // distinctly: the first is a macro with arguments, the second without. // Distinguish these cases using the column number, since we don't
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Wed Nov 12 03:59:40 GMT 2025 - 12.4K bytes - Click Count (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/ftp/FtpClientTest.java
fail(); } catch (final ChildUrlsException e) { final Set<RequestData> urlSet = e.getChildUrlList(); assertEquals(5, urlSet.size()); final List<String> urlList = urlSet.stream().map(x -> x.getUrl()).sorted().toList(); assertEquals("ftp://localhost:10021/dir1", urlList.get(0)); assertEquals("ftp://localhost:10021/dir2", urlList.get(1));
Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Mon Nov 24 03:59:47 GMT 2025 - 21.5K bytes - Click Count (0) -
android/guava/src/com/google/common/primitives/UnsignedInts.java
* compares, using {@link #compare(int, int)}), the first pair of values that follow any common * prefix, or when one array is a prefix of the other, treats the shorter array as the lesser. For * example, {@code [] < [1] < [1, 2] < [2] < [1 << 31]}. * * <p>The returned comparator is inconsistent with {@link Object#equals(Object)} (since arraysCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Feb 09 16:22:33 GMT 2025 - 13.8K bytes - Click Count (0) -
cmd/object-multipart-handlers.go
case authTypeStreamingSigned, authTypeStreamingSignedTrailer: // Initialize stream signature verifier. reader, s3Error = newSignV4ChunkedReader(r, rAuthType == authTypeStreamingSignedTrailer) if s3Error != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } case authTypeStreamingUnsignedTrailer: // Initialize stream signature verifier.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 07 16:13:09 GMT 2025 - 39.5K bytes - Click Count (1) -
src/main/java/org/codelibs/fess/app/web/admin/dict/mapping/AdminDictMappingAction.java
verifyTokenKeep(() -> downloadpage(form.dictId)); return charMappingService.getCharMappingFile(form.dictId) .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> { file.writeOut(out); })) .orElseGet(() -> { throwValidationError(messages -> messages.addErrorsFailedToDownloadMappingFile(GLOBAL),
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 22.3K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/suggest/entity/SuggestItemTest.java
assertTrue(dest.contains("existing")); assertTrue(dest.contains("new1")); assertTrue(dest.contains("new2")); // Should not have duplicate "existing" assertEquals(1, dest.stream().filter(s -> s.equals("existing")).count()); } @Test public void testConcatKinds() { // Test static concatKinds method SuggestItem.Kind[] kinds1 = { SuggestItem.Kind.QUERY };
Created: Sat Dec 20 13:04:59 GMT 2025 - Last Modified: Mon Sep 01 13:33:03 GMT 2025 - 16.7K bytes - Click Count (0) -
cmd/object-handlers.go
case authTypeStreamingSigned, authTypeStreamingSignedTrailer: // Initialize stream signature verifier. rd, s3Err = newSignV4ChunkedReader(r, rAuthType == authTypeStreamingSignedTrailer) if s3Err != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Err), r.URL) return } case authTypeStreamingUnsignedTrailer: // Initialize stream chunked reader with optional trailers.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 120.6K bytes - Click Count (0) -
lib/fips140/v1.0.0-c2097c7c.zip
#define IN_LEN R9 #define COUNTER R10 #define CONPTR R14 #define MASK V5 // Implementation of the counterCrypt function in assembler. // Original loop is unrolled to allow for multiple encryption // streams to be done in parallel, which is achieved by interleaving // vcipher instructions from each stream. This is also referred to as // stitching, and provides significant performance improvements. // Some macros are defined which enable execution for big or little // endian as well as different ISA...
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Thu Sep 25 19:53:19 GMT 2025 - 642.7K bytes - Click Count (0) -
src/test/java/jcifs/smb/SmbRandomAccessFileTest.java
ArgumentCaptor<Integer> lenCap = ArgumentCaptor.forClass(Integer.class); verify(raf, atLeast(2)).write(any(byte[].class), anyInt(), lenCap.capture()); assertTrue(lenCap.getAllValues().stream().allMatch(len -> len == 1)); } @Test @DisplayName("write(short/char/int/long/float/double): correct byte lengths") void write_multiByteVariants_lengths() throws Exception {
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 18.1K bytes - Click Count (0) -
cmd/object-api-interface.go
WantServerSideChecksumType hash.ChecksumType // if set, we compute a server-side checksum of this type NoDecryption bool // indicates if the stream must be decrypted. PreserveETag string // preserves this etag during a PUT call. NoLock bool // indicates to lower layers if the caller is expecting to hold locks.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 17.5K bytes - Click Count (0)