- Sort Score
- Num 10 results
- Language All
Results 121 - 130 of 493 for streams (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
tests/test_dependency_after_yield_streaming.py
@app.get("/data") def get_data(session: SessionDep) -> Any: data = list(session) return data @app.get("/stream-simple") def get_stream_simple(session: SessionDep) -> Any: def iter_data(): yield from ["x", "y", "z"] return StreamingResponse(iter_data()) @app.get("/stream-session") def get_stream_session(session: SessionDep) -> Any: def iter_data(): yield from session
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 21:25:59 GMT 2025 - 3.2K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildStep.java
} } public void executeBefore(BuildStep stepToExecuteAfter) { stepToExecuteAfter.executeAfter(this); } public Stream<MojoExecution> executions() { return mojos.values().stream().flatMap(m -> m.values().stream()); } @Override public boolean equals(Object o) { if (this == o) { return true; }Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Wed Apr 30 16:21:08 GMT 2025 - 4.9K bytes - Click Count (0) -
impl/maven-core/src/test/java/org/apache/maven/internal/transformation/impl/ConsumerPomArtifactTransformerTest.java
assertEquals(3, artifacts.size()); // original jar + consumer pom + build pom assertTrue(artifacts.stream().anyMatch(a -> "pom".equals(a.getExtension()) && "".equals(a.getClassifier()))); assertTrue( artifacts.stream().anyMatch(a -> "pom".equals(a.getExtension()) && "build".equals(a.getClassifier()))); } @Test void testDeployBuildPomDisabled() {
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Thu Nov 06 18:32:25 GMT 2025 - 13.3K bytes - Click Count (0) -
internal/config/crypto.go
Ciphertext: metadata.KMSKey, AssociatedData: associatedData, }) if err != nil { return nil, err } stream, err := metadata.Algorithm.Stream(key) if err != nil { return nil, err } if stream.NonceSize() != len(metadata.Nonce) { return nil, sio.NotAuthentic } return stream.DecryptReader(ciphertext, metadata.Nonce, nil), nil } type encryptedObject struct { KeyID string `json:"keyid"`Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 16 14:27:42 GMT 2025 - 4.7K bytes - Click Count (0) -
android/guava/src/com/google/common/io/LittleEndianDataInputStream.java
@J2ktIncompatible @GwtIncompatible public final class LittleEndianDataInputStream extends FilterInputStream implements DataInput { /** * Creates a {@code LittleEndianDataInputStream} that wraps the given stream. * * @param in the stream to delegate to */ public LittleEndianDataInputStream(InputStream in) { super(Preconditions.checkNotNull(in)); } /** This method will throw an {@link UnsupportedOperationException}. */Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Feb 12 03:49:18 GMT 2025 - 7.3K bytes - Click Count (0) -
internal/s3select/simdj/reader.go
"github.com/minio/minio/internal/s3select/sql" "github.com/minio/simdjson-go" ) // Reader - JSON record reader for S3Select. type Reader struct { args *json.ReaderArgs input chan simdjson.Stream decoded chan simdjson.Object // err will only be returned after decoded has been closed. err *error readCloser io.ReadCloser onReaderExit func() exitReader chan struct{}Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultLifecycleRegistry.java
public Iterator<Lifecycle> iterator() { return stream().toList().iterator(); } @Override public Stream<Lifecycle> stream() { return providers.stream().map(ExtensibleEnumProvider::provides).flatMap(Collection::stream); } @Override public Optional<Lifecycle> lookup(String id) { return stream().filter(lf -> Objects.equals(id, lf.id())).findAny(); }
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Mon Sep 29 14:45:25 GMT 2025 - 20.1K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/EnumHashBiMap.java
private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(keyTypeOrObjectUnderJ2cl); Serialization.writeMap(this, stream); } @SuppressWarnings("unchecked") // reading field populated by writeObject @GwtIncompatible // java.io.ObjectInputStream private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 15:50:50 GMT 2025 - 5.2K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt
* corresponding response body stream. This is necessary if we want servers to be able to stop * inbound data and send an early 400 before the request body completes. * * This test sends a slow request that is canceled by the server. It expects the response to still * be readable after the request stream is canceled. */ @Disabled @Test
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 25.8K bytes - Click Count (0) -
compat/maven-repository-metadata/src/main/java/org/apache/maven/artifact/repository/metadata/io/xpp3/MetadataXpp3Writer.java
} } /** * Method write. * * @param stream a stream object * @param metadata a Metadata object * @throws java.io.IOException java.io.IOException if any */ public void write(OutputStream stream, Metadata metadata) throws java.io.IOException { try { delegate.write(stream, metadata.getDelegate()); } catch (XMLStreamException e) {Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 2.5K bytes - Click Count (0)