- Sort Score
- Num 10 results
- Language All
Results 251 - 260 of 1,059 for Streams (0.06 seconds)
-
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/storage/StorageClientTest.java
.object("file1.txt") .stream(new ByteArrayInputStream("file1".getBytes()), 5, -1) .contentType("application/octet-stream") .build()); minioClient.putObject(PutObjectArgs.builder() .bucket(bucketName) .object("dir1/file2.txt") .stream(new ByteArrayInputStream("file2".getBytes()), 5, -1)
Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Mon Nov 24 03:59:47 GMT 2025 - 20.9K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultLifecycleRegistry.java
public Iterator<Lifecycle> iterator() { return stream().toList().iterator(); } @Override public Stream<Lifecycle> stream() { return providers.stream().map(ExtensibleEnumProvider::provides).flatMap(Collection::stream); } @Override public Optional<Lifecycle> lookup(String id) { return stream().filter(lf -> Objects.equals(id, lf.id())).findAny(); }
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Mon Sep 29 14:45:25 GMT 2025 - 20.1K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2Test.kt
frame.writeByte(Http2.TYPE_HEADERS) frame.writeByte(FLAG_END_HEADERS or FLAG_PRIORITY) frame.writeInt(expectedStreamId and 0x7fffffff) frame.writeInt(0) // Independent stream. frame.writeByte(255) // Heaviest weight, zero-indexed. frame.writeAll(headerBytes) reader.nextFrame( requireSettings = false, object : BaseTestHandler() { override fun priority(
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 28.1K bytes - Click Count (0) -
src/test/java/jcifs/smb/CredentialsInternalTest.java
import static org.mockito.Mockito.lenient; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.times; import static org.mockito.Mockito.verifyNoMoreInteractions; import java.util.stream.Stream; import javax.security.auth.Subject; import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.Nested; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith;
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 9.9K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/fileconfig/ApiAdminFileconfigAction.java
body.permissions = stream(entity.getPermissions()).get(stream -> stream.map(s -> permissionHelper.decode(s)) .filter(StringUtil::isNotBlank) .distinct() .collect(Collectors.joining("\n"))); body.virtualHosts = stream(entity.getVirtualHosts())
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 9.2K bytes - Click Count (0) -
src/main/java/jcifs/pac/ASN1Util.java
/** * Reads the next ASN.1 object from a stream and casts it to the specified type * @param <T> the target ASN.1 primitive type * @param type the target class type * @param stream the ASN.1 input stream * @return next object from stream cast to type * @throws PACDecodingException if types are incompatible * @throws IOException if reading from stream fails */Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 8.2K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/MavenParser.java
import java.io.IOException; import java.nio.charset.StandardCharsets; import java.nio.file.Files; import java.nio.file.Path; import java.util.ArrayList; import java.util.List; import java.util.stream.Stream; import org.apache.commons.cli.ParseException; import org.apache.maven.api.cli.Options; import org.apache.maven.api.cli.mvn.MavenOptions; import org.apache.maven.cling.invoker.BaseParser;
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Tue Oct 14 12:35:44 GMT 2025 - 4.4K bytes - Click Count (0) -
src/test/java/jcifs/smb1/util/MimeMapTest.java
void testUnknownExtension() throws IOException { assertEquals("application/octet-stream", mimeMap.getMimeType("unknownext")); assertEquals("application/octet-stream", mimeMap.getMimeType("notfound")); assertEquals("application/octet-stream", mimeMap.getMimeType("doesnotexist")); } @Test @DisplayName("Should handle case insensitive extensions")
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 9.1K bytes - Click Count (0) -
cmd/testdata/undeleteable-object.tgz
Kƒ¤Type ¥V2ObjÞ ¢IDÄ ¤DDirÄ ‰ Z•`=A#µß ñN`áÚ¦EcAlgo £EcM £EcN §EcBSizeÒ §EcIndex ¦EcDistœ ¨CSumAlgo ¨PartNums‘ ©PartETagsÀ©PartSizes‘ ªPartASizes‘ ¤Size ¥MTimeÓ É ¸í80§MetaSys ¼x-minio-internal-inline-dataÄ true§MetaUsr‚¬content-type¸application/octet-stream¤etagÙ 08ba8b8411960c5bc1e2¡v ΰ\ Ë ¤nullÄ%O‹óãB !EÆÐ ÃóÑÑä´.5t Ã*uºÅ{ _dùrd=EC multisitea/data/disterasure/xl3/.minio.sys/config/iam/format.json/xl.meta XL2 Æ o Ä$•Ä Ó ÉŸþ¦ ÆHÄ ¼… Å Cƒ¤Type ¥V2ObjÞ ¢IDÄ ¤DDirÄ ÷ ·_ñ7MùtyÑ ÿ? ¦EcAlgo £EcM £EcN §EcBSizeÒ...Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Apr 26 00:31:12 GMT 2024 - 8.7M bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/Extractor.java
/** * The Extractor interface defines methods for extracting text data from an input stream. * Implementations of this interface should provide the logic for extracting text and * optionally override the default weight value. */ public interface Extractor { /** * Extracts text data from the given input stream. * * @param in the input stream to extract text fromCreated: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Sat Mar 15 06:52:00 GMT 2025 - 1.6K bytes - Click Count (0)