Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 807 for stream (0.04 sec)

  1. src/main/java/org/codelibs/fess/job/CrawlJob.java

                if ("debug".equalsIgnoreCase(logLevel)) {
                    cmdList.add("-Dorg.apache.tika.service.error.warn=true");
                }
            }
            stream(fessConfig.getJvmCrawlerOptionsAsArray())
                    .of(stream -> stream.filter(StringUtil::isNotBlank).forEach(value -> cmdList.add(value)));
    
            File ownTmpDir = null;
            final String tmpDir = System.getProperty("java.io.tmpdir");
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 19.6K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/suggest/entity/SuggestItem.java

    import java.util.ArrayList;
    import java.util.Arrays;
    import java.util.Collections;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.fess.suggest.constants.FieldNames;
    import org.codelibs.fess.suggest.constants.SuggestConstants;
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 25.1K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/util/RenderDataUtil.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.util;
    
    import java.util.Collection;
    import java.util.List;
    import java.util.stream.Collectors;
    
    import org.codelibs.core.beans.util.BeanUtil;
    import org.dbflute.Entity;
    import org.lastaflute.web.response.render.RenderData;
    
    /**
     * Utility class for managing render data in web responses.
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 2.6K bytes
    - Viewed (0)
  4. src/main/java/jcifs/pac/kerberos/KerberosRelevantAuthData.java

            ASN1Sequence authSequence;
            try {
                try (ASN1InputStream stream = new ASN1InputStream(new ByteArrayInputStream(token))) {
                    authSequence = ASN1Util.as(ASN1Sequence.class, stream);
                }
            } catch (IOException e) {
                throw new PACDecodingException("Malformed kerberos ticket", e);
            }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 3K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/collect/ImmutableEnumMapTest.java

    import com.google.common.collect.testing.features.CollectionSize;
    import com.google.common.testing.CollectorTester;
    import java.util.HashMap;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.stream.Collector;
    import java.util.stream.Stream;
    import junit.framework.Test;
    import junit.framework.TestCase;
    import junit.framework.TestSuite;
    import org.jspecify.annotations.NullMarked;
    
    /**
     * Tests for {@code ImmutableEnumMap}.
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/HashBiMap.java

        private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        Serialization.writeMap(this, stream);
      }
    
      @GwtIncompatible
      @J2ktIncompatible
        private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
        stream.defaultReadObject();
        int size = Serialization.readCount(stream);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 36.2K bytes
    - Viewed (0)
  7. guava/src/com/google/common/hash/HashingOutputStream.java

       * unspecified if this method is called more than once on the same instance.
       */
      public HashCode hash() {
        return hasher.hash();
      }
    
      // Overriding close() because FilterOutputStream's close() method pre-JDK8 has bad behavior:
      // it silently ignores any exception thrown by flush(). Instead, just close the delegate stream.
      // It should flush itself if necessary.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/io/ByteSinkTest.java

          TestByteSink okSink = new TestByteSink();
          assertThrows(IOException.class, () -> failSource.copyTo(okSink));
          // ensure stream was closed IF it was opened (depends on implementation whether or not it's
          // opened at all if source.newInputStream() throws).
          assertTrue(
              "stream not closed when copying from source with option: " + option,
              !okSink.wasStreamOpened() || okSink.wasStreamClosed());
        }
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/io/ByteSinkTest.java

          TestByteSink okSink = new TestByteSink();
          assertThrows(IOException.class, () -> failSource.copyTo(okSink));
          // ensure stream was closed IF it was opened (depends on implementation whether or not it's
          // opened at all if source.newInputStream() throws).
          assertTrue(
              "stream not closed when copying from source with option: " + option,
              !okSink.wasStreamOpened() || okSink.wasStreamClosed());
        }
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  10. docs/bucket/versioning/DESIGN.md

    `xl.meta` carries first 8 bytes an XL header which describes the current format and the format version,
    allowing the unmarshaller's to automatically use the right data structures to parse the subsequent content in the stream.
    
    ### v1.0
    
    | Entry     | Encoding    | Content
    | ----------|-------------|----------------------------------------
    | xlHeader  | [4]byte     | `'X', 'L', '2', ' '`
    | xlVersion | [4]byte     | `'1', ' ', ' ', ' '`
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Jul 17 15:43:14 UTC 2022
    - 5.8K bytes
    - Viewed (0)
Back to top