Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 18 for jetstream (0.06 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

          stream!!.receiveHeaders(headerBlock.toHeaders(), inFinished)
        }
    
        override fun rstStream(
          streamId: Int,
          errorCode: ErrorCode,
        ) {
          if (pushedStream(streamId)) {
            pushResetLater(streamId, errorCode)
            return
          }
          val rstStream = removeStream(streamId)
          rstStream?.receiveRstStream(errorCode)
        }
    
        override fun settings(
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 31.9K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/primitives/ImmutableIntArrayTest.java

        assertThat(iia.asList()).containsExactly(0, 1, 3).inOrder();
      }
    
      public void testCopyOf_stream() {
        assertThat(ImmutableIntArray.copyOf(IntStream.empty()))
            .isSameInstanceAs(ImmutableIntArray.of());
        assertThat(ImmutableIntArray.copyOf(IntStream.of(0, 1, 3)).asList())
            .containsExactly(0, 1, 3)
            .inOrder();
      }
    
      public void testBuilder_presize_zero() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 12 14:49:24 GMT 2025
    - 20.6K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/collect/Streams.java

      }
    
      /**
       * Returns an {@link IntStream} containing the elements of the first stream, followed by the
       * elements of the second stream, and so on.
       *
       * <p>This is equivalent to {@code Stream.of(streams).flatMapToInt(stream -> stream)}, but the
       * returned stream may perform better.
       *
       * @see IntStream#concat(IntStream, IntStream)
       */
      public static IntStream concat(IntStream... streams) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 36.8K bytes
    - Click Count (0)
  4. guava/src/com/google/common/collect/Streams.java

      }
    
      /**
       * Returns an {@link IntStream} containing the elements of the first stream, followed by the
       * elements of the second stream, and so on.
       *
       * <p>This is equivalent to {@code Stream.of(streams).flatMapToInt(stream -> stream)}, but the
       * returned stream may perform better.
       *
       * @see IntStream#concat(IntStream, IntStream)
       */
      public static IntStream concat(IntStream... streams) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 36.4K bytes
    - Click Count (0)
  5. src/test/java/org/codelibs/fess/llm/LlmChatRequestTest.java

        }
    
        @Test
        public void test_setStream() {
            final LlmChatRequest request = new LlmChatRequest();
    
            final LlmChatRequest result = request.setStream(true);
    
            assertSame(request, result);
            assertTrue(request.isStream());
        }
    
        @Test
        public void test_fluentBuilding() {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Jan 14 14:29:07 GMT 2026
    - 5.8K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/cache/LocalCacheMapComputeTest.java

    import java.util.List;
    import java.util.Queue;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.concurrent.ExecutionException;
    import java.util.function.IntConsumer;
    import java.util.stream.IntStream;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /** Test Java8 map.compute in concurrent cache context. */
    @NullUnmarked
    public class LocalCacheMapComputeTest extends TestCase {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 6.4K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/primitives/ImmutableIntArray.java

     * <Integer>}:
     *
     * <ul>
     *   <li>Improved memory compactness and locality.
     *   <li>Can be queried without allocating garbage.
     *   <li>Access to {@code IntStream} features (like {@link IntStream#sum}) using {@code stream()}
     *       instead of the awkward {@code stream().mapToInt(v -> v)}.
     * </ul>
     *
     * <p>Disadvantages compared to {@code ImmutableList<Integer>}:
     *
     * <ul>
    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)
  8. src/main/java/org/codelibs/fess/llm/LlmChatRequest.java

        }
    
        /**
         * Sets whether streaming is enabled.
         *
         * @param stream true to enable streaming
         * @return this request for method chaining
         */
        public LlmChatRequest setStream(final boolean stream) {
            this.stream = stream;
            return this;
        }
    
        /**
         * Gets the thinking budget for models that support thinking tokens.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 05 03:38:31 GMT 2026
    - 6.4K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/llm/AbstractLlmClient.java

            }
            final String context = buildContext(documents, "answer");
            final LlmChatRequest request = buildStreamingRequest(userMessage, context, history);
            request.setStream(true);
    
            streamChatWithConcurrencyControl(request, callback);
        }
    
        @Override
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 21 06:04:58 GMT 2026
    - 72K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt

        val errorCodeInt = source.readInt()
        val errorCode =
          ErrorCode.fromHttp2(errorCodeInt) ?: throw IOException(
            "TYPE_RST_STREAM unexpected error code: $errorCodeInt",
          )
        handler.rstStream(streamId, errorCode)
      }
    
      @Throws(IOException::class)
      private fun readSettings(
        handler: Handler,
        length: Int,
        flags: Int,
        streamId: Int,
      ) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 19.7K bytes
    - Click Count (0)
Back to Top