- Sort Score
- Result 10 results
- Languages All
Results 401 - 410 of 838 for stream (0.04 sec)
-
docs/extensions/fan-out/README.md
MinIO implements an S3 extension to the [PostUpload](https://docs.aws.amazon.com/AmazonS3/latest/API/RESTObjectPOST.html) where in a special fan-out list is sent along with the TSB's for MinIO make multiple uploads from a single source stream. Optionally supports custom metadata, tags and other retention settings. All objects are also readable independently once upload is completed via the regular S3 [GetObject](https://docs.aws.amazon.com/AmazonS3/latest/API/API_GetObject.html) API.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 25 05:51:07 UTC 2023 - 1.4K bytes - Viewed (0) -
src/main/java/jcifs/pac/kerberos/KerberosEncData.java
ASN1InputStream stream = new ASN1InputStream(new ByteArrayInputStream(token)); ASN1TaggedObject derToken; try { derToken = ASN1Util.as(ASN1TaggedObject.class, stream); if ( derToken.getTagClass() != BERTags.APPLICATION ) throw new PACDecodingException("Malformed kerberos ticket"); stream.close(); } catch ( IOException e ) {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Mon Oct 02 12:02:06 UTC 2023 - 11.4K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/impl/SisuDiBridgeModule.java
import java.util.Comparator; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Set; import java.util.function.Function; import java.util.function.Supplier; import java.util.stream.Collectors; import com.google.inject.AbstractModule; import com.google.inject.Binder; import com.google.inject.name.Names; import com.google.inject.spi.ProviderInstanceBinding;
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 10.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
* may never exhaust the source stream and therefore not complete the cached response. */ @Throws(IOException::class) private fun cacheWritingResponse( cacheRequest: CacheRequest?, response: Response, ): Response { // Some apps return a null body; for compatibility we treat that like a null cache request.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Fri Mar 22 07:09:21 UTC 2024 - 10.2K bytes - Viewed (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/building/DefaultModelProcessor.java
public Path locatePom(Path projectDirectory) { // Note that the ModelProcessor#locatePom never returns null // while the ModelParser#locatePom needs to return an existing path! Path pom = modelParsers.stream() .map(m -> m.locate(projectDirectory) .map(org.apache.maven.api.services.Source::getPath) .orElse(null)) .filter(Objects::nonNull)
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 8.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/pathmap/ApiAdminPathmapAction.java
*/ package org.codelibs.fess.app.web.api.admin.pathmap; import static org.codelibs.fess.app.web.admin.pathmap.AdminPathmapAction.getPathMapping; import java.util.List; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.Constants; import org.codelibs.fess.app.pager.PathMapPager;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 5.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/relatedcontent/ApiAdminRelatedcontentAction.java
*/ package org.codelibs.fess.app.web.api.admin.relatedcontent; import static org.codelibs.fess.app.web.admin.relatedcontent.AdminRelatedcontentAction.getRelatedContent; import java.util.List; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.app.pager.RelatedContentPager; import org.codelibs.fess.app.service.RelatedContentService;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 6.4K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/graph/DefaultProjectDependencyGraph.java
import java.util.Collections; import java.util.Comparator; import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Objects; import java.util.Set; import java.util.stream.Collectors; import org.apache.maven.execution.ProjectDependencyGraph; import org.apache.maven.project.CycleDetectedException; import org.apache.maven.project.DuplicateProjectException;
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 5.8K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlFilterService.java
import java.util.HashSet; import java.util.List; import java.util.Set; import java.util.concurrent.ExecutionException; import java.util.concurrent.TimeUnit; import java.util.regex.Pattern; import java.util.stream.Collectors; import org.codelibs.fess.crawler.entity.OpenSearchUrlFilter; import org.codelibs.fess.crawler.exception.CrawlerSystemException; import org.codelibs.fess.crawler.service.UrlFilterService;
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 6.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/OsddHelper.java
return osddFile != null; } public StreamResponse asStream() { if (osddFile == null) { throw ComponentUtil.getResponseManager().new404("Unsupported Open Search Description Document response."); } return new StreamResponse(osddFile.getName()).contentType(contentType + "; charset=" + encoding).stream(out -> { try (InputStream ins = new FileInputStream(osddFile)) {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 3.7K bytes - Viewed (0)