- Sort Score
- Result 10 results
- Languages All
Results 291 - 300 of 850 for Streams (0.1 sec)
-
src/main/java/org/codelibs/fess/helper/SystemHelper.java
return designJspFileNameMap.entrySet().stream().map(e -> new Pair<>(e.getKey(), e.getValue())).toArray(n -> new Pair[n]); } public List<Path> refreshDesignJspFiles() { final List<Path> fileList = new ArrayList<>(); stream(ComponentUtil.getVirtualHostHelper().getVirtualHostPaths()) .of(stream -> stream.filter(s -> s != null && !"/".equals(s)).forEach(key -> {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Oct 17 12:10:08 UTC 2024 - 27.2K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
"github.com/minio/minio/internal/s3select/sql" "github.com/minio/simdjson-go" ) // Reader - JSON record reader for S3Select. type Reader struct { args *json.ReaderArgs input chan simdjson.Stream decoded chan simdjson.Object // err will only be returned after decoded has been closed. err *error readCloser io.ReadCloser onReaderExit func() exitReader chan struct{}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 30 17:02:22 UTC 2023 - 4.9K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/execution/DefaultBuildResumptionAnalyzer.java
boolean hasNoSuccess = sortedProjects.stream().noneMatch(project -> result.getBuildSummary(project) instanceof BuildSuccess); if (hasNoSuccess) { return Optional.empty(); } List<String> remainingProjects = sortedProjects.stream() .filter(project -> result.getBuildSummary(project) == null
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 2.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/crawler/transformer/FessXpathTransformer.java
stream(crawlingConfig.getPermissions()).of(stream -> stream.forEach(p -> roleTypeList.add(p))); putResultDataBody(dataMap, fessConfig.getIndexFieldRole(), roleTypeList); // virtualHosts putResultDataBody(dataMap, fessConfig.getIndexFieldVirtualHost(), stream(crawlingConfig.getVirtualHosts()).get(stream -> stream.filter(StringUtil::isNotBlank).collect(Collectors.toList())));
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Oct 24 13:01:38 UTC 2024 - 42.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/storage/AdminStorageAction.java
final PutObjectArgs args = PutObjectArgs.builder().bucket(fessConfig.getStorageBucket()).object(objectName) .stream(in, uploadFile.getFileSize(), -1).contentType("application/octet-stream").build(); minioClient.putObject(args); } catch (final Exception e) { throw new StorageException("Failed to upload " + objectName, e); } }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 19.9K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/XIncludeAwareXmlProvider.groovy
import javax.xml.transform.OutputKeys import javax.xml.transform.Transformer import javax.xml.transform.TransformerFactory import javax.xml.transform.dom.DOMSource import javax.xml.transform.stream.StreamResult import org.w3c.dom.Document import org.w3c.dom.Element import org.w3c.dom.Node class XIncludeAwareXmlProvider { Document root Element parse(File sourceFile) {
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Dec 09 08:14:05 UTC 2020 - 2.2K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/ChecksumAlgorithmService.java
throws IOException; /** * Calculates checksums for specified stream. Upon this method returns, the stream will be depleted (fully read) * but not closed. * * @param stream The stream for which to calculate checksums, must not be {@code null}. * @param algorithms The checksum algorithms to use, must not be {@code null}.
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Wed Jul 10 20:52:34 UTC 2024 - 6.4K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/artifact/repository/metadata/io/MetadataReader.java
*/ Metadata read(Reader input, Map<String, ?> options) throws IOException, MetadataParseException; /** * Reads the metadata from the specified byte stream. The stream will be automatically closed before the method * returns. * * @param input The stream to deserialize the metadata from, must not be {@code null}. * @param options The options to use for deserialization, may be {@code null} to use the default values.
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 3.3K bytes - Viewed (0) -
compat/maven-settings-builder/src/main/java/org/apache/maven/settings/io/SettingsReader.java
*/ Settings read(Reader input, Map<String, ?> options) throws IOException, SettingsParseException; /** * Reads the settings from the specified byte stream. The stream will be automatically closed before the method * returns. * * @param input The stream to deserialize the settings from, must not be {@code null}. * @param options The options to use for deserialization, may be {@code null} to use the default values.
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 3.4K bytes - Viewed (0) -
compat/maven-toolchain-builder/src/main/java/org/apache/maven/toolchain/io/ToolchainsReader.java
/** * Reads the toolchains from the specified byte stream. The stream will be automatically closed before the method * returns. * * @param input The stream to deserialize the toolchains from, must not be {@code null}. * @param options The options to use for deserialization, may be {@code null} to use the default values.
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 3.5K bytes - Viewed (0)