Search Options

Results per page
Sort
Preferred Languages
Advance

Results 591 - 600 of 849 for upstream (0.11 sec)

  1. guava/src/com/google/common/collect/ImmutableRangeSet.java

    import java.io.ObjectInputStream;
    import java.io.Serializable;
    import java.util.Collections;
    import java.util.Iterator;
    import java.util.List;
    import java.util.NoSuchElementException;
    import java.util.Set;
    import java.util.stream.Collector;
    import javax.annotation.CheckForNull;
    
    /**
     * A {@link RangeSet} whose contents will never change, with many other important properties
     * detailed at {@link ImmutableCollection}.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 27K bytes
    - Viewed (0)
  2. docs/changelogs/changelog_1x.md

       currently-shipping versions.
     * Support asynchronous disconnects by breaking the socket only. This should
       prevent flakiness from multiple threads concurrently accessing a stream.
    
    ## Version 1.5.3
    
    _2014-03-29_
    
     * Fix bug where the Content-Length header was not always dropped when
       following a redirect from a POST to a GET.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 6.4K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/-ResponseBodyCommon.kt

      }
    
      val bytes = source().use(consumer)
      val size = sizeMapper(bytes)
      if (contentLength != -1L && contentLength != size.toLong()) {
        throw IOException("Content-Length ($contentLength) and stream length ($size) disagree")
      }
      return bytes
    }
    
    internal fun ResponseBody.commonClose() = source().closeQuietly()
    
    internal fun ByteArray.commonToResponseBody(contentType: MediaType?): ResponseBody {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/ImmutableAsList.java

          return collection.asList();
        }
    
        private static final long serialVersionUID = 0;
      }
    
      @GwtIncompatible // serialization
      @J2ktIncompatible
      private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use SerializedForm");
      }
    
      @GwtIncompatible // serialization
      @J2ktIncompatible
      @Override
      Object writeReplace() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Mar 06 16:06:58 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  5. internal/deadlineconn/deadlineconn.go

    // Package deadlineconn implements net.Conn wrapper with configured deadlines.
    package deadlineconn
    
    import (
    	"net"
    	"time"
    )
    
    const updateInterval = 250 * time.Millisecond
    
    // DeadlineConn - is a generic stream-oriented network connection supporting buffered reader and read/write timeout.
    type DeadlineConn struct {
    	net.Conn
    	readDeadline  time.Duration // sets the read deadline on a connection.
    	readSetAt     time.Time
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 17:40:11 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/Synchronized.java

          synchronized (mutex) {
            return delegate().spliterator();
          }
        }
    
        @Override
        public Stream<E> stream() {
          synchronized (mutex) {
            return delegate().stream();
          }
        }
    
        @Override
        public Stream<E> parallelStream() {
          synchronized (mutex) {
            return delegate().parallelStream();
          }
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 57.2K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java

        }
    
        @PreDestroy
        public void destroy() {
            if (logger.isDebugEnabled()) {
                logger.debug("cache stats: {}", statsCache.stats());
            }
            statsCache.asMap().entrySet().stream().forEach(e -> {
                final StatsObject data = e.getValue();
                final Long begin = data.remove(BEGIN_KEY);
                if (begin != null) {
                    printStats(e.getKey(), data, begin, false);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/transformer/impl/BinaryTransformer.java

                resultData.setEncoding(responseData.getCharSet());
                return resultData;
            } catch (final IOException e) {
                throw new CrawlerSystemException("Could not convert the input stream.", e);
            }
    
        }
    
        /*
         * (non-Javadoc)
         *
         * @see
         * org.codelibs.fess.crawler.transformer.Transformer#getData(org.codelibs.fess.crawler.entity
         * .AccessResultData)
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  9. build-logic/build-init-samples/src/main/kotlin/gradlebuild/samples/SamplesGenerator.kt

    import org.gradle.buildinit.plugins.internal.modifiers.ComponentType
    import org.gradle.buildinit.plugins.internal.modifiers.Language
    import org.gradle.buildinit.plugins.internal.modifiers.ModularizationOption
    
    import java.util.stream.Collectors
    
    
    object SamplesGenerator {
    
        fun generate(type: String, modularization: ModularizationOption, templateFolder: Directory, target: Directory, projectLayoutSetupRegistry: ProjectLayoutSetupRegistry) {
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Oct 22 11:11:17 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/AbstractCrawlerClient.java

        private static final Logger logger = LoggerFactory.getLogger(AbstractCrawlerClient.class);
    
        protected static final String APPLICATION_OCTET_STREAM = "application/octet-stream";
    
        public static final String ACCESS_TIMEOUT_PROPERTY = "accessTimeout";
    
        public static final String MAX_CONTENT_LENGTH = "maxContentLength";
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 5.9K bytes
    - Viewed (0)
Back to top