- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for Streaming (0.07 sec)
-
android/guava-tests/test/com/google/common/hash/AbstractNonStreamingHashFunctionTest.java
/** Tests for AbstractNonStreamingHashFunction. */ @NullUnmarked public class AbstractNonStreamingHashFunctionTest extends TestCase { /** * Constructs two trivial HashFunctions (output := input), one streaming and one non-streaming, * and checks that their results are identical, no matter which newHasher version we used. */ public void testExhaustive() { List<Hasher> hashers = ImmutableList.of(Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 4.5K bytes - Viewed (0) -
README.md
## Version [Versions in Maven Repository](https://repo1.maven.org/maven2/org/codelibs/jcifs/) ## Requirements - Java 17 or higher - SLF4J for logging
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 09:24:52 UTC 2025 - 6.2K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/entity/SitemapVideo.java
public void setPlatform(final String platform) { this.platform = platform; } /** * Gets the live streaming flag. * @return the live value */ public String getLive() { return live; } /** * Sets the live streaming flag. * @param live the live value to set */ public void setLive(final String live) { this.live = live;
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 13 13:34:36 UTC 2025 - 8.9K bytes - Viewed (0) -
README.md
- `org.codelibs.curl.CurlResponse`: wrapper for HTTP responses. - `org.codelibs.curl.CurlException`: unchecked exception for errors. - `org.codelibs.curl.io.ContentCache` and `ContentOutputStream`: internal utilities for streaming and caching. Refer to the Javadoc for full API details. ## Building and Testing ```bash git clone https://github.com/codelibs/curl4j.git cd curl4j mvn clean test ``` ## License
Registered: Sat Dec 20 09:13:53 UTC 2025 - Last Modified: Thu Nov 20 13:34:13 UTC 2025 - 2.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/CompressionInterceptor.kt
val response = chain.proceed(request) decompress(response) } else { chain.proceed(chain.request()) } /** * Returns a decompressed copy of the Response, typically via a streaming Source. * If no known decompression or the response is not compressed, returns the response unmodified. */ internal fun decompress(response: Response): Response { if (!response.promisesBody()) {Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Oct 07 15:15:28 UTC 2025 - 2.9K bytes - Viewed (1) -
CLAUDE.md
### I/O Layer - **`org.codelibs.curl.io.ContentCache`**: Handles automatic in-memory or on-disk caching of request/response bodies - **`org.codelibs.curl.io.ContentOutputStream`**: Streaming utilities for efficient content handling ### Key Design Patterns 1. **Fluent Builder Pattern**: `CurlRequest` uses method chaining for configuration
Registered: Sat Dec 20 09:13:53 UTC 2025 - Last Modified: Mon Nov 24 03:10:07 UTC 2025 - 3.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/thumbnail/ThumbnailAction.java
// Attribute // /** * HTTP servlet response for streaming thumbnail images. */ @Resource protected HttpServletResponse response; // ===================================================================================Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 4.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/go/GoAction.java
* to the target URL or serves file content directly if configured. * * @param form the go form containing document ID and tracking parameters * @return action response for redirection or content streaming * @throws IOException if an I/O error occurs during content retrieval */ @Execute public ActionResponse index(final GoForm form) throws IOException {Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Dec 11 09:47:03 UTC 2025 - 9K bytes - Viewed (0) -
guava/src/com/google/common/hash/AbstractNonStreamingHashFunction.java
import com.google.errorprone.annotations.Immutable; import java.nio.ByteBuffer; import java.nio.ByteOrder; import java.nio.charset.Charset; /** * Skeleton implementation of {@link HashFunction}, appropriate for non-streaming algorithms. All * the hash computation done using {@linkplain #newHasher()} are delegated to the {@linkplain * #hashBytes(byte[], int, int)} method. * * @author Dimitris Andreou */ @ImmutableRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 04 15:39:10 UTC 2025 - 4.8K bytes - Viewed (0) -
docs/contribute/concurrency.md
arrive, the stream is closed, or a timeout elapses. If we get bytes but there's nobody asking for them, we buffer them. We don't consider bytes as delivered for flow control until they're consumed by the application. Consider an application streaming a video over http/2. Perhaps the user pauses the video and the application stops reading bytes from this stream. The buffer will fill up, and flow control prevents the server from sending more data on this stream. When the user unpauses her video...
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 7K bytes - Viewed (0)