- Sort Score
- Num 10 results
- Language All
Results 731 - 740 of 1,059 for Streams (0.04 seconds)
-
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) -
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 @J2ktIncompatibleCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Nov 17 22:50:48 GMT 2025 - 4.3K bytes - Click Count (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)