Search Options

Results per page
Sort
Preferred Languages
Advance

Results 631 - 640 of 852 for jstream (0.13 sec)

  1. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/BasicJavadocLexer.java

    package gradlebuild.docs.dsl.docbook;
    
    import java.util.HashMap;
    import java.util.Locale;
    import java.util.Map;
    import java.util.regex.Pattern;
    
    /**
     * Converts the main description of a javadoc comment into a stream of tokens.
     */
    class BasicJavadocLexer implements JavadocLexer {
        private static final Pattern HTML_ELEMENT = Pattern.compile("(?s)<\\\\?[^<]+?>");
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Mon Aug 19 15:07:24 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  2. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/core/misc/DynamicProperties.java

            getProperties().list(out);
        }
    
        @Override
        public synchronized void load(final InputStream inStream) throws IOException {
            final Properties prop = new Properties();
            lastModified = propertiesFile.lastModified();
            prop.load(inStream);
            properties = prop;
        }
    
        @Override
        public synchronized void load(final Reader reader) throws IOException {
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  4. cmd/bitrot.go

    	if algo != HighwayHash256S {
    		return size
    	}
    	return ceilFrac(size, shardSize)*int64(algo.New().Size()) + size
    }
    
    // bitrotVerify a single stream of data.
    func bitrotVerify(r io.Reader, wantSize, partSize int64, algo BitrotAlgorithm, want []byte, shardSize int64) error {
    	if algo != HighwayHash256S {
    		h := algo.New()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/Multisets.java

       * will be added more than once, with the count summed over all appearances of the element.
       *
       * <p>Note that {@code stream.collect(toMultiset(function, e -> 1, supplier))} is equivalent to
       * {@code stream.map(function).collect(Collectors.toCollection(supplier))}.
       *
       * <p>To collect to an {@link ImmutableMultiset}, use {@link
       * ImmutableMultiset#toImmutableMultiset}.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 41.7K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/Multisets.java

       * will be added more than once, with the count summed over all appearances of the element.
       *
       * <p>Note that {@code stream.collect(toMultiset(function, e -> 1, supplier))} is equivalent to
       * {@code stream.map(function).collect(Collectors.toCollection(supplier))}.
       *
       * <p>To collect to an {@link ImmutableMultiset}, use {@link
       * ImmutableMultiset#toImmutableMultiset}.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 41.5K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/app/web/cache/CacheAction.java

            if (content == null) {
                saveError(messages -> messages.addErrorsDocidNotFound(GLOBAL, form.docId));
                return redirect(ErrorAction.class);
            }
    
            final StreamResponse response = asStream(DocumentUtil.getValue(doc, fessConfig.getIndexFieldDocId(), String.class))
                    .contentType("text/html; charset=UTF-8").data(content.getBytes(Constants.CHARSET_UTF_8));
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  8. docs/orchestration/README.md

    |:---------------------------------------------------------------------------------------------------|
    | [`Kubernetes`](https://min.io/docs/minio/kubernetes/upstream/index.html#quickstart-for-kubernetes)                                |
    
    ## Why is MinIO cloud-native?
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 2.2K bytes
    - Viewed (0)
  9. mockwebserver/README.md

    from your test's `tearDown()`.
    
    ### API
    
    #### MockResponse
    
    Mock responses default to an empty response body and a `200` status code.
    You can set a custom body with a string, input stream or byte array. Also
    add headers with a fluent builder API.
    
    ```java
    MockResponse response = new MockResponse()
        .addHeader("Content-Type", "application/json; charset=utf-8")
        .addHeader("Cache-Control", "no-cache")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Dec 17 15:34:10 UTC 2023
    - 5K bytes
    - Viewed (0)
  10. docs/features/calls.md

    ## [Requests](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-request/)
    
    Each HTTP request contains a URL, a method (like `GET` or `POST`), and a list of headers. Requests may also contain a body: a data stream of a specific content type.
    
    ## [Responses](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-response/)
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 3.9K bytes
    - Viewed (0)
Back to top