- Sort Score
- Num 10 results
- Language All
Results 21 - 30 of 956 for stream (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
android/guava/src/com/google/common/collect/Streams.java
} } /** * Returns a {@link Stream} 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).flatMap(stream -> stream)}, but the returned * stream may perform better. * * @see Stream#concat(Stream, Stream) */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) -
guava/src/com/google/common/collect/FluentIterable.java
* iterator supports it. * * <p><b>{@code Stream} equivalent:</b> to concatenate an arbitrary number of streams, use {@code * Stream.of(stream1, stream2, ...).flatMap(s -> s)}. If the sources are iterables, use {@code * Stream.of(iter1, iter2, ...).flatMap(Streams::stream)}. * * @throws NullPointerException if any of the provided iterables is {@code null} * @since 20.0Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Apr 02 14:49:41 GMT 2026 - 34.7K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/FluentIterable.java
* iterator supports it. * * <p><b>{@code Stream} equivalent:</b> to concatenate an arbitrary number of streams, use {@code * Stream.of(stream1, stream2, ...).flatMap(s -> s)}. If the sources are iterables, use {@code * Stream.of(iter1, iter2, ...).flatMap(Streams::stream)}. * * @throws NullPointerException if any of the provided iterables is {@code null} * @since 20.0Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Apr 02 14:49:41 GMT 2026 - 34.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.acceptFrame() // HEADERS STREAM 3 peer.acceptFrame() // DATA STREAM 3 "abcde" peer.acceptFrame() // HEADERS STREAM 3 peer.play() // Play it back. val connection = connect(peer) val stream = connection.newStream(headerEntries("a", "android"), true) stream.enqueueTrailers(headersOf("foo", "bar")) val sink = stream.sink.buffer() sink.writeUtf8("abcdefghi")
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 75.5K bytes - Click Count (0) -
src/main/java/org/codelibs/core/stream/StreamUtil.java
* Executes the provided {@link Consumer} with a {@link Stream} obtained from the supplier. * The stream is automatically closed after the consumer is executed. * * @param stream the {@link Consumer} to process the {@link Stream} */ public void of(final Consumer<Stream<T>> stream) { try (Stream<T> s = supplier.get()) { stream.accept(s); } }Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Thu Jul 31 08:16:49 GMT 2025 - 4.4K bytes - Click Count (0) -
guava/src/com/google/common/collect/Serialization.java
Map<K, V> map, ObjectOutputStream stream) throws IOException { stream.writeInt(map.size()); for (Map.Entry<K, V> entry : map.entrySet()) { stream.writeObject(entry.getKey()); stream.writeObject(entry.getValue()); } } /** * Populates a map by reading an input stream, as part of deserialization. See {@link #writeMap} * for the data format. */
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Dec 09 15:58:48 GMT 2025 - 6.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/mylasta/direction/FessProp.java
} return list.stream().map(p -> { final String key = p.getFirst(); if (StringUtil.isEmpty(key) || userBean .map(user -> stream(user.getRoles()).get(stream -> stream.anyMatch(s -> (ROLE_VALUE_PREFIX + s).equals(key))) || stream(user.getGroups()).get(stream -> stream.anyMatch(s -> (GROUP_VALUE_PREFIX + s).equals(key))))Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 92.3K bytes - Click Count (0) -
src/main/java/org/codelibs/core/io/CopyUtil.java
// from InputStream to OutputStream // /** * Copies from an input stream to an output stream. * <p> * Neither the input stream nor the output stream is closed. * </p> * * @param in the input stream (must not be {@literal null}) * @param out the output stream (must not be {@literal null}) * @return the number of bytes copied */Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Thu Jul 31 08:16:49 GMT 2025 - 45.2K bytes - Click Count (0) -
docs_src/stream_data/tutorial001_py310.py
""" @app.get("/story/stream", response_class=StreamingResponse) async def stream_story() -> AsyncIterable[str]: for line in message.splitlines(): yield line @app.get("/story/stream-no-async", response_class=StreamingResponse) def stream_story_no_async() -> Iterable[str]: for line in message.splitlines(): yield line @app.get("/story/stream-no-annotation", response_class=StreamingResponse)
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Feb 27 18:56:47 GMT 2026 - 2.2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/PopularWordHelper.java
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 7.3K bytes - Click Count (0)