Search Options

Results per page
Sort
Preferred Languages
Advance

Results 901 - 910 of 1,022 for Streams (0.1 sec)

  1. 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
    ```java
    MockResponse response = new MockResponse.Builder()
        .addHeader("Content-Type", "application/json; charset=utf-8")
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Oct 30 21:39:59 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/helper/PermissionHelper.java

                try {
                    if (fileAttributeView instanceof final AclFileAttributeView aclFileAttributeView) {
                        aclFileAttributeView.getAcl().stream().forEach(acl -> {
                            final UserPrincipal principal = acl.principal();
                            if (logger.isDebugEnabled()) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 13 05:54:52 UTC 2025
    - 15.4K bytes
    - Viewed (0)
  3. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableList.java

    import java.util.Arrays;
    import java.util.Collection;
    import java.util.Collections;
    import java.util.Comparator;
    import java.util.Iterator;
    import java.util.List;
    import java.util.RandomAccess;
    import java.util.stream.Collector;
    import jsinterop.annotations.JsMethod;
    import org.jspecify.annotations.Nullable;
    
    /**
     * GWT emulated version of {@link com.google.common.collect.ImmutableList}. TODO(cpovirk): more doc
     *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Aug 06 18:32:41 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  4. cmd/encryption-v1.go

    	if err != nil {
    		return encryptedETag
    	}
    	return hex.EncodeToString(etagBytes)
    }
    
    // GetDecryptedRange - To decrypt the range (off, length) of the
    // decrypted object stream, we need to read the range (encOff,
    // encLength) of the encrypted object stream to decrypt it, and
    // compute skipLen, the number of bytes to skip in the beginning of
    // the encrypted range.
    //
    // In addition we also compute the object part number for where the
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 38K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/JodExtractor.java

         */
        @Override
        public ExtractData getText(final InputStream in, final Map<String, String> params) {
            if (in == null) {
                throw new CrawlerSystemException("JODConverter input stream is null. Cannot extract text from null input.");
            }
    
            final String resourceName = params == null ? null : params.get(ExtractData.RESOURCE_NAME_KEY);
    
            String extension;
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Nov 23 12:19:14 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  6. src/test/java/jcifs/http/HandlerTest.java

        }
    
        @Test
        void testOpenConnection_WithCustomFactory() throws Exception {
            // This test verifies that if a custom URLStreamHandlerFactory is set, it is used
            // to create the stream handler for the connection.
            URLStreamHandlerFactory mockFactory = mock(URLStreamHandlerFactory.class);
    
            // Create a concrete URLStreamHandler subclass instead of mocking
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  7. compat/maven-compat/src/main/java/org/apache/maven/project/interpolation/AbstractStringBasedModelInterpolator.java

     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.project.interpolation;
    
    import javax.inject.Inject;
    import javax.xml.stream.XMLStreamException;
    
    import java.io.File;
    import java.io.IOException;
    import java.io.StringReader;
    import java.io.StringWriter;
    import java.util.ArrayList;
    import java.util.Arrays;
    import java.util.Collections;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 13.6K bytes
    - Viewed (0)
  8. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnup/goals/PluginUpgradeStrategy.java

    import java.nio.file.Files;
    import java.nio.file.Path;
    import java.util.Comparator;
    import java.util.HashMap;
    import java.util.HashSet;
    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.stream.Collectors;
    
    import eu.maveniverse.domtrip.Document;
    import eu.maveniverse.domtrip.Editor;
    import eu.maveniverse.domtrip.Element;
    import org.apache.maven.api.RemoteRepository;
    import org.apache.maven.api.Session;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Tue Nov 18 18:03:26 UTC 2025
    - 37K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Response.kt

       * response was received without TLS.
       */
      @get:JvmName("handshake") val handshake: Handshake?,
      /** Returns the HTTP headers. */
      @get:JvmName("headers") val headers: Headers,
      /**
       * Returns a non-null stream with the server's response. The returned value must be
       * [closed][ResponseBody] and may be consumed only once.
       *
       * If this is a [cacheResponse], [networkResponse], or [priorResponse], the server's response body
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon Jul 28 14:39:28 UTC 2025
    - 18.1K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Hpack.kt

                headerCount,
              )
              nextHeaderIndex += entriesToEvict
            }
            return entriesToEvict
          }
    
          /**
           * Read `byteCount` bytes of headers from the source stream. This implementation does not
           * propagate the never indexed flag of a header.
           */
          @Throws(IOException::class)
          fun readHeaders() {
            while (!source.exhausted()) {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 22.4K bytes
    - Viewed (0)
Back to top