Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 731 - 740 of 1,059 for Streams (0.04 seconds)

  1. android/guava/src/com/google/common/base/Converter.java

     *       converter.reverse().convertAll(bs)}.
     *   <li>Use {@code converter} or {@code converter.reverse()} anywhere a {@link
     *       java.util.function.Function} is accepted (for example {@link java.util.stream.Stream#map
     *       Stream.map}).
     *   <li><b>Do not</b> call {@link #doForward} or {@link #doBackward} directly; these exist only to
     *       be overridden.
     * </ul>
     *
     * <h3>Example</h3>
     *
     * {@snippet :
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Jun 18 21:43:06 GMT 2025
    - 22.8K bytes
    - Click Count (0)
  2. guava/src/com/google/common/collect/ImmutableMapEntrySet.java

      @J2ktIncompatible
        @Override
      Object writeReplace() {
        return new EntrySetSerializedForm<>(map());
      }
    
      @GwtIncompatible
      @J2ktIncompatible
        private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use EntrySetSerializedForm");
      }
    
      @GwtIncompatible
      @J2ktIncompatible
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Nov 17 22:50:48 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/ResponseBodyJvmTest.kt

          }
        assertFailsWith<IOException> {
          body.bytes()
        }.also { expected ->
          assertThat(expected.message).isEqualTo(
            "Content-Length (10) and stream length (5) disagree",
          )
        }
      }
    
      @Test
      fun bytesThrowsMoreThanIntMaxValue() {
        val body: ResponseBody =
          object : ResponseBody() {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 12.4K bytes
    - Click Count (0)
  4. okcurl/src/main/kotlin/okhttp3/curl/internal/-MainCommon.kt

        if (showHeaders) {
          println(StatusLine.get(response))
          val headers = response.headers
          for ((name, value) in headers) {
            println("$name: $value")
          }
          println()
        }
    
        // Stream the response to the System.out as it is returned from the server.
        val out = System.out.sink()
        val source = response.body.source()
        while (!source.exhausted()) {
          out.write(source.buffer, source.buffer.size)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  5. impl/maven-core/src/main/java/org/apache/maven/plugin/internal/DeprecatedCoreExpressionValidator.java

                ExpressionEvaluator expressionEvaluator) {
            if (mojoDescriptor.getParameters() == null) {
                return;
            }
    
            mojoDescriptor.getParameters().stream()
                    .filter(this::isDeprecated)
                    .map(this::formatParameter)
                    .forEach(m -> pluginValidationManager.reportPluginMojoValidationIssue(
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 3.5K bytes
    - Click Count (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/net/protocol/gcs/Handler.java

                    throw new IOException("Failed to create GCS client.", e);
                }
            }
    
            /**
             * Gets an input stream to read from the GCS object.
             *
             * @return An input stream for reading the object content
             * @throws IOException If the object cannot be accessed
             */
            @Override
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Thu Dec 11 08:38:29 GMT 2025
    - 9.6K bytes
    - Click Count (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/net/protocol/s3/Handler.java

                    throw new IOException("Failed to create S3Client.", e);
                }
            }
    
            /**
             * Gets an input stream to read from the S3 object.
             *
             * @return An input stream for reading the object content
             * @throws IOException If the object cannot be accessed
             */
            @Override
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Thu Dec 11 07:57:44 GMT 2025
    - 9.5K bytes
    - Click Count (0)
  8. src/test/java/jcifs/internal/smb2/nego/Smb2NegotiateResponseTest.java

    import static org.mockito.Mockito.mock;
    import static org.mockito.Mockito.verifyNoInteractions;
    import static org.mockito.Mockito.when;
    
    import java.lang.reflect.Field;
    import java.lang.reflect.Method;
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.BeforeEach;
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.params.ParameterizedTest;
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 32.5K bytes
    - Click Count (0)
  9. ci/devinfra/README.md

    > directory are stable and appropriate documentation around its usage is in
    > place.
    
    Maintainer: TensorFlow DevInfra
    
    Issue Reporting: File an issue against this repo and tag
    [@devinfra](https://github.com/orgs/tensorflow/teams/devinfra)
    
    ********************************************************************************
    
    A directory for build and CI related scripts and jobs managed by the TensorFlow
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Tue Jun 06 21:00:01 GMT 2023
    - 732 bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/app/web/admin/design/AdminDesignAction.java

                    return true;
                }
            }
            return false;
        }
    
        /**
         * Download a design file.
         * @param form The file access form.
         * @return The stream response.
         */
        @Execute
        @Secured({ ROLE, ROLE + VIEW })
        public StreamResponse download(final FileAccessForm form) {
            final File file = getTargetFile(form.fileName).get();
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 17.4K bytes
    - Click Count (0)
Back to Top