Search Options

Results per page
Sort
Preferred Languages
Advance

Results 521 - 530 of 729 for streams (0.07 sec)

  1. src/test/java/org/codelibs/fess/helper/IndexingHelperTest.java

    import java.util.Collections;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.atomic.AtomicReference;
    import java.util.function.BiConsumer;
    import java.util.stream.Collectors;
    
    import org.codelibs.fess.app.service.WebConfigService;
    import org.codelibs.fess.mylasta.direction.FessConfig;
    import org.codelibs.fess.opensearch.client.SearchEngineClient;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 19 23:49:30 UTC 2025
    - 29.3K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/app/web/admin/systeminfo/AdminSysteminfoAction.java

         */
        public static List<Map<String, String>> getFessPropItems(final FessConfig fessConfig) {
            final List<Map<String, String>> itemList = new ArrayList<>();
            ComponentUtil.getSystemProperties().entrySet().stream().forEach(e -> {
                final String k = e.getKey().toString();
                final String value;
                if (isMaskedValue(k)) {
                    value = MASKED_VALUE;
                } else {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 9.7K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/util/mime.map

    application/mac-binhex40       hqx              # Macintosh binhexed archives
    application/mspowerpoint       ppt              # Microsoft Powerpoint
    application/msword             doc              # Microsoft Word
    application/octet-stream       bin exe ani      # Binary File
    application/oda                oda
    application/pagemaker          pm5 pt5 pm       # PageMaker
    application/pdf                pdf              # Adobe Acrobat
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 5.9K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/collect/ImmutableSortedMapTest.java

    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.Set;
    import java.util.SortedMap;
    import java.util.TreeMap;
    import java.util.function.BiPredicate;
    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;
    import org.jspecify.annotations.Nullable;
    
    /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 27.6K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/EmptyContiguousSet.java

      @J2ktIncompatible
        @Override
      Object writeReplace() {
        return new SerializedForm<>(domain);
      }
    
      @GwtIncompatible
      @J2ktIncompatible
        private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use SerializedForm");
      }
    
      @GwtIncompatible // NavigableSet
      @Override
      ImmutableSortedSet<C> createDescendingSet() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/service/CrawlingInfoService.java

    import java.time.LocalDateTime;
    import java.time.format.DateTimeFormatter;
    import java.util.ArrayList;
    import java.util.Collections;
    import java.util.List;
    import java.util.Set;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.CoreLibConstants;
    import org.codelibs.core.beans.util.BeanUtil;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 19.9K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/BridgeInterceptor.kt

          requestBuilder.header("Connection", "Keep-Alive")
        }
    
        // If we add an "Accept-Encoding: gzip" header field we're responsible for also decompressing
        // the transfer stream.
        var transparentGzip = false
        if (userRequest.header("Accept-Encoding") == null && userRequest.header("Range") == null) {
          transparentGzip = true
          requestBuilder.header("Accept-Encoding", "gzip")
        }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  8. cmd/test-utils_test.go

    		signature = hex.EncodeToString(sumHMAC(signingKey, []byte(stringToSign)))
    
    		stream = append(stream, []byte(fmt.Sprintf("%x", n)+";chunk-signature="+signature+"\r\n")...)
    		stream = append(stream, buffer[:n]...)
    		stream = append(stream, []byte("\r\n")...)
    
    		if n <= 0 {
    			break
    		}
    	}
    	req.Body = io.NopCloser(bytes.NewReader(stream))
    	return req, nil
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  9. src/test/java/jcifs/smb/SmbFileOutputStreamTest.java

                    SmbConstants.O_CREAT | SmbConstants.O_WRONLY | SmbConstants.O_TRUNC, SmbConstants.FILE_WRITE_DATA,
                    SmbConstants.DEFAULT_SHARING);
    
            // Close the stream
            outputStream.close();
    
            // When & Then - after close, tmp is null so write(int) will throw NullPointerException
            // This is the actual behavior of the implementation
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Call.kt

    package okhttp3
    
    import okio.IOException
    import okio.Timeout
    
    /**
     * A call is a request that has been prepared for execution. A call can be canceled. As this object
     * represents a single request/response pair (stream), it cannot be executed twice.
     */
    interface Call : Cloneable {
      /** Returns the original request that initiated this call. */
      fun request(): Request
    
      /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 3.6K bytes
    - Viewed (0)
Back to top