- Sort Score
- Num 10 results
- Language All
Results 1051 - 1060 of 1,233 for jstream (0.06 seconds)
-
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")
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Oct 30 21:39:59 GMT 2025 - 8.1K bytes - Click Count (0) -
src/test/java/org/codelibs/core/io/PropertiesUtilTest.java
/** * */ private static final long serialVersionUID = 1L; @Override public synchronized void load(final InputStream inStream) throws IOException { throw new IOException("load"); } } /** * {@link org.codelibs.core.io.PropertiesUtil#load(Properties, String)} */ @TestCreated: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Sat May 10 01:32:17 GMT 2025 - 9.6K bytes - Click Count (0) -
android/guava/src/com/google/common/eventbus/EventBus.java
* <p>To react to events, we recommend a reactive-streams framework like <a * href="https://github.com/ReactiveX/RxJava/wiki">RxJava</a> (supplemented with its <a * href="https://github.com/ReactiveX/RxAndroid">RxAndroid</a> extension if you are building for * Android) or <a href="https://projectreactor.io/">Project Reactor</a>. (For the basics of * translating code from using an event bus to using a reactive-streams framework, see these two
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 12.7K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/it/admin/JobLogTests.java
response = checkMethodBase(searchBody).get(API_PATH + "/logs").asString(); List<Map<String, Object>> afterLogs = JsonPath.from(response).getList("response.logs"); boolean logDeleted = afterLogs.stream().noneMatch(log -> logId.equals(log.get("id").toString())); assertTrue(logDeleted, "Log should be deleted"); logger.info("[END] testDeleteJobLog"); } /**
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 21 13:29:45 GMT 2025 - 9.9K bytes - Click Count (0) -
guava/src/com/google/common/collect/AbstractMapBasedMultiset.java
} // Don't allow default serialization. @GwtIncompatible @J2ktIncompatible private void readObjectNoData() throws ObjectStreamException { throw new InvalidObjectException("Stream data required"); } @GwtIncompatible @J2ktIncompatible private static final long serialVersionUID = -2250766705698539974L;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Aug 11 19:31:30 GMT 2025 - 10.2K bytes - Click Count (0) -
guava/src/com/google/common/collect/RegularImmutableBiMap.java
Object writeReplace() { return new InverseSerializedForm<>(RegularImmutableBiMap.this); } @J2ktIncompatible // java.io.ObjectInputStream private void readObject(ObjectInputStream stream) throws InvalidObjectException { throw new InvalidObjectException("Use InverseSerializedForm"); } } @J2ktIncompatible // serialization
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 26 20:08:09 GMT 2025 - 11.1K bytes - Click Count (0) -
cmd/api-headers.go
return fmt.Sprintf("%X", t.UnixNano()) } // setEventStreamHeaders to allow proxies to avoid buffering proxy responses func setEventStreamHeaders(w http.ResponseWriter) { w.Header().Set(xhttp.ContentType, "text/event-stream") w.Header().Set(xhttp.CacheControl, "no-cache") // nginx to turn off buffering w.Header().Set("X-Accel-Buffering", "no") // nginx to turn off buffering } // Write http common headers
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt
// If this succeeds, too many requests were made. executeSynchronously("/") .assertFailure(IOException::class.java) .assertFailureMatches( "stream was reset: CANCEL", "unexpected end of stream on " + server.url("/").redact(), ) } @RetryingTest(5) @Flaky fun recoverWhenRetryOnConnectionFailureIsFalse_HTTP2() { enableProtocol(Protocol.HTTP_2)Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:02:18 GMT 2026 - 146.5K bytes - Click Count (0) -
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 mockingCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 11.1K bytes - Click Count (0) -
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;
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 13.6K bytes - Click Count (0)