Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 835 for streams (0.12 sec)

  1. docs/en/docs/advanced/custom-response.md

    ///
    
    ### `FileResponse`
    
    Asynchronously streams a file as the response.
    
    Takes a different set of arguments to instantiate than the other response types:
    
    * `path` - The file path to the file to stream.
    * `headers` - Any custom headers to include, as a dictionary.
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 12K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/MoreCollectors.java

      /**
       * A collector that converts a stream of zero or one elements to an {@code Optional}.
       *
       * @throws IllegalArgumentException if the stream consists of two or more elements.
       * @throws NullPointerException if any element in the stream is {@code null}.
       * @return {@code Optional.of(onlyElement)} if the stream has exactly one element (must not be
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/ImmutableTable.java

       *
       * @since 33.2.0 (available since 21.0 in guava-jre)
       */
      @SuppressWarnings("Java7ApiChecker")
      @IgnoreJRERequirement // Users will use this only if they're already using streams.
      public static <T extends @Nullable Object, R, C, V>
          Collector<T, ?, ImmutableTable<R, C, V>> toImmutableTable(
              Function<? super T, ? extends R> rowFunction,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/primitives/ImmutableDoubleArray.java

        }
      }
    
      /**
       * Returns a stream over the values in this array, in order.
       *
       * @since NEXT (but since 22.0 in the JRE flavor)
       */
      @SuppressWarnings("Java7ApiChecker")
      // If users use this when they shouldn't, we hope that NewApi will catch subsequent stream calls
      @IgnoreJRERequirement
      public DoubleStream stream() {
        return Arrays.stream(array, start, end);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 18:05:56 UTC 2024
    - 23K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/package-info.java

     *   <li>{@link Maps}
     *   <li>{@link MoreCollectors}
     *   <li>{@link Multimaps}
     *   <li>{@link Multisets}
     *   <li>{@link ObjectArrays}
     *   <li>{@link Queues}
     *   <li>{@link Sets}
     *   <li>{@link Streams}
     *   <li>{@link Tables}
     * </ul>
     *
     * <h2>Abstract implementations</h2>
     *
     * <ul>
     *   <li>{@link AbstractIterator}
     *   <li>{@link AbstractSequentialIterator}
     *   <li>{@link UnmodifiableIterator}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Jul 06 16:29:45 UTC 2023
    - 5K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/package-info.java

     *   <li>{@link Maps}
     *   <li>{@link MoreCollectors}
     *   <li>{@link Multimaps}
     *   <li>{@link Multisets}
     *   <li>{@link ObjectArrays}
     *   <li>{@link Queues}
     *   <li>{@link Sets}
     *   <li>{@link Streams}
     *   <li>{@link Tables}
     * </ul>
     *
     * <h2>Abstract implementations</h2>
     *
     * <ul>
     *   <li>{@link AbstractIterator}
     *   <li>{@link AbstractSequentialIterator}
     *   <li>{@link UnmodifiableIterator}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Jul 06 16:29:45 UTC 2023
    - 5K bytes
    - Viewed (0)
  7. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

          sleepNanos(response.headersDelayNanos)
          stream.writeHeaders(response.toHttp2Headers(), outFinished, flushHeaders)
    
          if (trailers.size > 0) {
            stream.enqueueTrailers(trailers)
          }
          pushPromises(stream, request, response.pushPromises)
          if (body != null) {
            sleepNanos(bodyDelayNanos)
            val responseBodySink =
              stream.getSink().withThrottlingAndSocketPolicy(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  8. guava/src/com/google/common/io/Resources.java

       *     helpful predefined constants
       * @return a string containing all the characters from the URL
       * @throws IOException if an I/O error occurs.
       */
      public static String toString(URL url, Charset charset) throws IOException {
        return asCharSource(url, charset).read();
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 13:50:22 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  9. cmd/dummy-data-generator_test.go

    }
    
    // NewDummyDataGen returns a ReadSeeker over the first `totalLength`
    // bytes from the infinite stream consisting of repeated
    // concatenations of `alphabets`.
    //
    // The skipOffset (generally = 0) can be used to skip a given number
    // of bytes from the beginning of the infinite stream. This is useful
    // to compare such streams of bytes that may be split up, because:
    //
    // Given the function:
    //
    //	f := func(r io.Reader) string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/ImmutableSortedMultiset.java

       *
       * @since 33.2.0 (available since 21.0 in guava-jre)
       */
      @SuppressWarnings("Java7ApiChecker")
      @IgnoreJRERequirement // Users will use this only if they're already using streams.
      public static <E> Collector<E, ?, ImmutableSortedMultiset<E>> toImmutableSortedMultiset(
          Comparator<? super E> comparator) {
        return toImmutableSortedMultiset(comparator, Function.identity(), e -> 1);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 35.4K bytes
    - Viewed (0)
Back to top