Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1051 - 1060 of 1,233 for jstream (0.06 seconds)

  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")
    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)
  2. 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)}
         */
        @Test
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Sat May 10 01:32:17 GMT 2025
    - 9.6K bytes
    - Click Count (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  10. 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)
Back to Top