Search Options

Results per page
Sort
Preferred Languages
Advance

Results 611 - 620 of 849 for upstream (0.08 sec)

  1. impl/maven-core/src/main/java/org/apache/maven/artifact/repository/metadata/io/DefaultMetadataReader.java

     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.artifact.repository.metadata.io;
    
    import javax.inject.Named;
    import javax.inject.Singleton;
    import javax.xml.stream.XMLStreamException;
    
    import java.io.File;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.Reader;
    import java.nio.file.Files;
    import java.util.Map;
    import java.util.Objects;
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  2. internal/bucket/lifecycle/tag.go

    )
    
    // UnmarshalXML - decodes XML data.
    func (tag *Tag) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    	var keyAlreadyParsed, valueAlreadyParsed bool
    	for {
    		// Read tokens from the XML document in a stream.
    		t, err := d.Token()
    		if err != nil {
    			if err == io.EOF {
    				break
    			}
    			return err
    		}
    
    		if se, ok := t.(xml.StartElement); ok {
    			var s string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  3. internal/ringbuffer/README.md

    Writes will block until there is space available and writes bigger than the buffer will wait for reads to make space.
    
    `TryRead` and `TryWrite` are still available for non-blocking reads and writes.
    
    To signify the end of the stream, close the ring buffer from the writer side with `rb.CloseWriter()`
    
    Either side can use `rb.CloseWithError(err error)` to signal an error and close the ring buffer. 
    Any reads or writes will return the error on next call.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/curl/CurlRequest.java

            }
            this.body = body;
            return this;
        }
    
        public CurlRequest body(final InputStream stream) {
            if (body != null) {
                throw new CurlException("body method is already called.");
            }
            this.bodyStream = stream;
            return this;
        }
    
        public CurlRequest onConnect(final BiConsumer<CurlRequest, HttpURLConnection> connectionBuilder) {
    Registered: Thu Oct 31 02:32:13 UTC 2024
    - Last Modified: Sun Feb 12 12:21:25 UTC 2023
    - 12.3K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/tls/ClientAuthTest.kt

      }
    
      @Flaky
      @RetryingTest(5)
      fun missingClientAuthFailsForNeeds() {
        // Fails with 11.0.1 https://github.com/square/okhttp/issues/4598
        // StreamReset stream was reset: PROT...
        val client = buildClient(null, clientIntermediateCa.certificate)
        val socketFactory = buildServerSslSocketFactory()
        server.useHttps(socketFactory)
        server.requireClientAuth()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/SitemapsHelper.java

                }
            }
            return false;
        }
    
        /**
         * Generates SitemapSet instance.
         *
         * This method does not close the input stream.
         *
         * @param in Input stream for a sitemap
         * @return a sitemap set
         */
        public SitemapSet parse(final InputStream in) {
            return parse(in, true);
        }
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Sat Oct 12 01:40:57 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  7. docs/changelogs/changelog_3x.md

    
    ## Version 3.14.5
    
    _2020-01-03_
    
     *  Fix: Degrade HTTP/2 connections after a timeout. When an HTTP/2 stream times out it may impact
        the stream only or the entire connection. With this fix OkHttp will now send HTTP/2 pings after
        a stream timeout to determine whether the connection should remain eligible for pooling.
    
    
    ## Version 3.14.4
    
    _2019-09-29_
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  8. okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt

          }
        }
      }
    
      private fun ResponseBody.isEventStream(): Boolean {
        val contentType = contentType() ?: return false
        return contentType.type == "text" && contentType.subtype == "event-stream"
      }
    
      override fun onFailure(
        call: Call,
        e: IOException,
      ) {
        listener.onFailure(this, e, null)
      }
    
      override fun request(): Request = request
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/curl/io/IOIntegrationTest.java

            logger.info("After close response. Number of temp files: " + after);
    
            // ## Assert ##
            assertEquals(before, after);
        }
    
        private long countTmpFiles() {
            return Arrays.stream(Objects.requireNonNull(Curl.tmpDir.listFiles())).map(File::getName)
                    .filter(s -> s.startsWith(PREFIX) && s.endsWith(SUFFIX)).count();
        }
    Registered: Thu Oct 31 02:32:13 UTC 2024
    - Last Modified: Mon Nov 14 21:05:19 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  10. compat/maven-embedder/src/main/java/org/apache/maven/cli/internal/BootstrapCoreExtensionManager.java

    import java.io.File;
    import java.util.ArrayList;
    import java.util.Collections;
    import java.util.List;
    import java.util.NoSuchElementException;
    import java.util.Set;
    import java.util.function.Function;
    import java.util.stream.Collectors;
    
    import org.apache.maven.RepositoryUtils;
    import org.apache.maven.api.Service;
    import org.apache.maven.api.Session;
    import org.apache.maven.api.cli.extensions.CoreExtension;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 13.2K bytes
    - Viewed (0)
Back to top