Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 55 for jetstream (0.6 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. compat/maven-model-builder/src/main/java/org/apache/maven/model/building/DefaultModelBuilder.java

    import java.util.LinkedHashSet;
    import java.util.List;
    import java.util.Map;
    import java.util.Objects;
    import java.util.Optional;
    import java.util.Properties;
    import java.util.function.Consumer;
    import java.util.stream.IntStream;
    
    import org.apache.maven.artifact.versioning.DefaultArtifactVersion;
    import org.apache.maven.artifact.versioning.InvalidVersionSpecificationException;
    import org.apache.maven.artifact.versioning.VersionRange;
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Sun Mar 30 23:08:08 GMT 2025
    - 55.3K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/primitives/ImmutableDoubleArrayTest.java

        ImmutableDoubleArray.of(0, 1, 2, 3)
            .forEach(i -> assertThat(i).isEqualTo((double) count.getAndIncrement()));
        assertThat(count.get()).isEqualTo(4);
      }
    
      public void testStream() {
        ImmutableDoubleArray.of().stream().forEach(i -> fail());
        ImmutableDoubleArray.of(0, 1, 3).subArray(1, 1).stream().forEach(i -> fail());
        assertThat(ImmutableDoubleArray.of(0, 1, 3).stream().toArray())
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 21.5K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/primitives/ImmutableDoubleArrayTest.java

        ImmutableDoubleArray.of(0, 1, 2, 3)
            .forEach(i -> assertThat(i).isEqualTo((double) count.getAndIncrement()));
        assertThat(count.get()).isEqualTo(4);
      }
    
      public void testStream() {
        ImmutableDoubleArray.of().stream().forEach(i -> fail());
        ImmutableDoubleArray.of(0, 1, 3).subArray(1, 1).stream().forEach(i -> fail());
        assertThat(ImmutableDoubleArray.of(0, 1, 3).stream().toArray())
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 12 14:49:24 GMT 2025
    - 21.9K bytes
    - Click Count (0)
  4. cmd/peer-rest-server.go

    	// STREAMS
    	// Set an output capacity of 100 for consoleLog and listenRPC
    	// There is another buffer that will buffer events.
    	consoleLogRPC = grid.NewStream[*grid.MSS, grid.NoPayload, *grid.Bytes](grid.HandlerConsoleLog, grid.NewMSS, nil, grid.NewBytes).WithOutCapacity(100)
    	listenRPC     = grid.NewStream[*grid.URLValues, grid.NoPayload, *grid.Bytes](grid.HandlerListen, grid.NewURLValues, nil, grid.NewBytes).WithOutCapacity(100)
    )
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/collect/FluentIterableTest.java

       * overkill when nearly all Streams are produced using well-tested JDK calls. So, we cheat and
       * just test that the toArray() contents are as expected.
       */
      public void testStream() {
        assertThat(FluentIterable.of().stream()).isEmpty();
        assertThat(FluentIterable.of("a").stream()).containsExactly("a");
        assertThat(FluentIterable.of(1, 2, 3).stream().filter(n -> n > 1)).containsExactly(2, 3);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 31.2K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2Test.kt

        frame.writeInt(expectedStreamId and 0x7fffffff)
        frame.writeInt(ErrorCode.PROTOCOL_ERROR.httpCode)
        reader.nextFrame(
          requireSettings = false,
          object : BaseTestHandler() {
            override fun rstStream(
              streamId: Int,
              errorCode: ErrorCode,
            ) {
              assertThat(streamId).isEqualTo(expectedStreamId)
              assertThat(errorCode).isEqualTo(ErrorCode.PROTOCOL_ERROR)
            }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 28.1K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/collect/FluentIterable.java

     *   <li>{@code FluentIterable} contains several features not available on {@code Stream}, which are
     *       noted in the method descriptions below.
     *   <li>Streams include primitive-specialized variants such as {@code IntStream}, the use of which
     *       is strongly recommended.
     *   <li>Streams are standard Java, not requiring a third-party dependency (but requiring <a
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Apr 02 14:49:41 GMT 2026
    - 34.7K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/primitives/Ints.java

        // There are several well-known algorithms for rotating part of an array (or, equivalently,
        // exchanging two blocks of memory). This classic text by Gries and Mills mentions several:
        // https://ecommons.cornell.edu/bitstream/handle/1813/6292/81-452.pdf.
        // (1) "Reversal", the one we have here.
        // (2) "Dolphin". If we're rotating an array a of size n by a distance of d, then element a[0]
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 16:45:58 GMT 2026
    - 31.3K bytes
    - Click Count (0)
  9. guava/src/com/google/common/collect/FluentIterable.java

     *   <li>{@code FluentIterable} contains several features not available on {@code Stream}, which are
     *       noted in the method descriptions below.
     *   <li>Streams include primitive-specialized variants such as {@code IntStream}, the use of which
     *       is strongly recommended.
     *   <li>Streams are standard Java, not requiring a third-party dependency.
     * </ul>
     *
     * <h3>Example</h3>
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Apr 02 14:49:41 GMT 2026
    - 34.7K bytes
    - Click Count (0)
  10. cmd/peer-rest-client.go

    	gridConn := client.gridConn()
    	if gridConn == nil {
    		return
    	}
    
    	payload, err := json.Marshal(traceOpts)
    	if err != nil {
    		bugLogIf(ctx, err)
    		return
    	}
    
    	st, err := gridConn.NewStream(ctx, grid.HandlerTrace, payload)
    	if err != nil {
    		return
    	}
    	st.Results(func(b []byte) error {
    		select {
    		case traceCh <- b:
    		default:
    			// Do not block on slow receivers.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
Back to Top