Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 671 - 680 of 858 for Streams (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/main/java/org/codelibs/fess/app/web/api/admin/storage/ApiAdminStorageAction.java

            if (StringUtil.isEmpty(pi.getName())) {
                throwValidationErrorApi(messages -> messages.addErrorsStorageFileNotFound(GLOBAL));
            }
            return asStream(pi.getName()).contentTypeOctetStream().stream(out -> {
                try {
                    downloadObject(getObjectName(pi.getPath(), pi.getName()), out);
                } catch (final StorageException e) {
                    logger.warn("Failed to download {}", id, e);
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 6.9K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/query/DefaultQueryBuilder.java

     */
    package org.codelibs.fess.query;
    
    import java.io.IOException;
    import java.util.Objects;
    
    import org.apache.lucene.search.Query;
    import org.opensearch.core.common.io.stream.StreamOutput;
    import org.opensearch.core.xcontent.XContentBuilder;
    import org.opensearch.index.query.BoolQueryBuilder;
    import org.opensearch.index.query.DisMaxQueryBuilder;
    import org.opensearch.index.query.QueryBuilder;
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  3. src/test/java/jcifs/smb1/https/HandlerTest.java

    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Nested;
    import org.junit.jupiter.api.Test;
    
    /**
     * Test suite for jcifs.smb1.https.Handler class.
     * Tests HTTPS URL stream handler functionality with NTLM authentication support.
     */
    @DisplayName("SMB1 HTTPS Handler Tests")
    class HandlerTest {
    
        private Handler handler;
    
        @BeforeEach
        void setUp() {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  4. impl/maven-core/src/test/java/org/apache/maven/project/PomConstructionTest.java

            Plugin plugin = plugins.stream()
                    .filter(p -> p.getArtifactId().equals(artifactId))
                    .findFirst()
                    .orElse(null);
            assertNotNull(plugin, "Unable to find plugin with artifactId: " + artifactId);
            List<PluginExecution> pluginExecutions = plugin.getExecutions();
            PluginExecution pluginExecution = pluginExecutions.stream()
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Sep 17 10:01:14 GMT 2025
    - 94.8K bytes
    - Click Count (0)
  5. docs/erasure/storage-class/README.md

    objectStat, err := object.Stat()
    if err != nil {
     log.Fatalln(err)
    }
    
    n, err := s3Client.PutObject("my-bucketname", "my-objectname", object, objectStat.Size(), minio.PutObjectOptions{ContentType: "application/octet-stream", StorageClass: "REDUCED_REDUNDANCY"})
    if err != nil {
     log.Fatalln(err)
    }
    log.Println("Uploaded", "my-objectname", " of size: ", n, "Successfully.")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 5.9K bytes
    - Click Count (0)
  6. build-logic/dependency-modules/src/main/kotlin/gradlebuild.dependency-modules.gradle.kts

     * limitations under the License.
     */
    
    import com.google.gson.Gson
    import com.google.gson.Strictness
    import com.google.gson.reflect.TypeToken
    import com.google.gson.stream.JsonReader
    import gradlebuild.basics.bundleGroovyMajor
    import gradlebuild.basics.repoRoot
    import gradlebuild.modules.extension.ExternalModulesExtension
    
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Fri Jul 18 11:32:19 GMT 2025
    - 9.3K bytes
    - Click Count (0)
  7. guava/src/com/google/common/collect/ImmutableRangeMap.java

    import java.util.List;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.NoSuchElementException;
    import java.util.function.BiFunction;
    import java.util.function.Function;
    import java.util.stream.Collector;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link RangeMap} whose contents will never change, with many other important properties
     * detailed at {@link ImmutableCollection}.
     *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 23 17:50:58 GMT 2025
    - 14.8K bytes
    - Click Count (0)
  8. guava/src/com/google/common/collect/ImmutableBiMap.java

    import java.io.ObjectInputStream;
    import java.util.Arrays;
    import java.util.Comparator;
    import java.util.Map;
    import java.util.function.BinaryOperator;
    import java.util.function.Function;
    import java.util.stream.Collector;
    import java.util.stream.Collectors;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link BiMap} whose contents will never change, with many other important properties detailed
     * at {@link ImmutableCollection}.
     *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 23 17:50:58 GMT 2025
    - 22.7K bytes
    - Click Count (0)
  9. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/logging/SystemStreamLog.java

     * under the License.
     */
    package org.apache.maven.plugin.logging;
    
    import java.io.PrintWriter;
    import java.io.StringWriter;
    
    /**
     * Logger with "standard" output and error output stream.
     *
     *
     * @deprecated Use SLF4J directly
     */
    @Deprecated
    public class SystemStreamLog implements Log {
        /**
         * @see org.apache.maven.plugin.logging.Log#debug(java.lang.CharSequence)
         */
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  10. api/maven-api-core/src/test/java/org/apache/maven/api/services/SourcesTest.java

            assertNull(source.resolve(locator, "subproject"));
            verify(locator, never()).locateExistingPom(any(Path.class));
        }
    
        @Test
        void testStreamReading() throws IOException {
            // Test stream reading functionality
            Path testFile = tempDir.resolve("test.txt");
            String content = "test content";
            Files.writeString(testFile, content);
    
            Source source = Sources.fromPath(testFile);
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Mon Sep 29 14:45:25 GMT 2025
    - 5.4K bytes
    - Click Count (0)
Back to Top