Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 754 for Streams (0.06 sec)

  1. src/main/java/org/codelibs/fess/helper/VirtualHostHelper.java

         * Gets all configured virtual host paths.
         *
         * @return An array of virtual host paths
         */
        public String[] getVirtualHostPaths() {
            return stream(ComponentUtil.getFessConfig().getVirtualHosts())
                    .get(stream -> stream.map(h -> "/" + h.getValue3()).toArray(n -> new String[n]));
        }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/helper/ThemeHelper.java

    import java.nio.file.StandardCopyOption;
    import java.util.Comparator;
    import java.util.stream.Stream;
    import java.util.zip.ZipEntry;
    import java.util.zip.ZipInputStream;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.stream.StreamUtil;
    import org.codelibs.fess.exception.ThemeException;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 7K bytes
    - Viewed (0)
  3. src/main/java/jcifs/SmbResource.java

         * @return output stream, needs to be closed when finished
         * @throws CIFSException if an error occurs accessing the resource
         */
        OutputStream openOutputStream(boolean append) throws CIFSException;
    
        /**
         * Opens an output stream writing to the file (truncating, write only, sharable)
         *
         * @return output stream, needs to be closed when finished
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 28K bytes
    - Viewed (1)
  4. src/test/java/org/codelibs/curl/CurlRequestTest.java

            CurlRequest request = new CurlRequest(Method.POST, "https://example.com");
            InputStream stream = new ByteArrayInputStream("test data".getBytes());
    
            CurlRequest result = request.body(stream);
    
            assertSame(request, result); // Fluent API
            assertNull(request.body()); // body() returns String body, not stream
        }
    
        @Test
        public void testBodyStringAfterStreamThrowsException() {
    Registered: Thu Sep 04 15:34:10 UTC 2025
    - Last Modified: Thu Jul 31 01:01:12 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/web/admin/general/AdminGeneralAction.java

                    postcard.setFrom(fessConfig.getMailFromAddress(), fessConfig.getMailFromName());
                    postcard.addReplyTo(fessConfig.getMailReturnPath());
                    stream(toAddresses).of(stream -> stream.forEach(address -> {
                        postcard.addTo(address);
                    }));
                    BeanUtil.copyMapToBean(dataMap, postcard);
                });
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 13.9K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb1/smb1/SmbNamedPipe.java

         * Pipe instance although this is not a requirement (e.g. a
         * read-only named pipe would write data to this stream on
         * connection). Reading from this stream may block. Therefore it
         * may be necessary that an addition thread be used to read and
         * write to a Named Pipe.
         * @return the input stream for reading from this pipe
         * @throws IOException if an I/O error occurs
         */
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  7. 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 Sep 07 03:35:12 UTC 2025
    - Last Modified: Wed Jul 10 20:52:34 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/crawler/util/FieldConfigs.java

             *
             * @param value the configuration value string to parse
             */
            public Config(final String value) {
                values = StreamUtil.split(value, Pattern.quote("|")).get(stream -> stream.map(String::trim).toArray(n -> new String[n]));
            }
    
            /**
             * Checks if the cache option is enabled in the configuration.
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/primitives/ImmutableLongArrayTest.java

        assertThat(count.get()).isEqualTo(4);
      }
    
      public void testStream() {
        ImmutableLongArray.of().stream().forEach(i -> fail());
        ImmutableLongArray.of(0, 1, 3).subArray(1, 1).stream().forEach(i -> fail());
        assertThat(ImmutableLongArray.of(0, 1, 3).stream().toArray()).isEqualTo(new long[] {0, 1, 3});
      }
    
      public void testSubArray() {
        ImmutableLongArray iia0 = ImmutableLongArray.of();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 20.5K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java

                        } else {
                            ignoreFields = new String[] { Constants.INDEXING_TARGET, Constants.SESSION_ID };
                        }
                        stream(ignoreFields).of(stream -> stream.map(String::trim).forEach(s -> dataMap.remove(s)));
    
                        indexUpdateCallback.store(paramMap, dataMap);
                        crawlerStatsHelper.record(keyObj, StatsAction.PROCESSED);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 28.9K bytes
    - Viewed (0)
Back to top