- Sort Score
- Num 10 results
- Language All
Results 1011 - 1020 of 1,261 for Stream (0.05 seconds)
-
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/test/GradleDistroTestTask.java
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 2.6K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/InternalDistributionArchiveCheckPlugin.java
import java.io.IOException; import java.nio.file.Files; import java.nio.file.Path; import java.util.Arrays; import java.util.List; import java.util.Map; import java.util.concurrent.Callable; import java.util.stream.Collectors; import org.elasticsearch.gradle.internal.conventions.GUtils; public class InternalDistributionArchiveCheckPlugin implements InternalPlugin { private ArchiveOperations archiveOperations; @InjectCreated: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 10.6K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/release/ChangelogEntry.java
import java.io.File; import java.io.IOException; import java.io.UncheckedIOException; import java.util.Arrays; import java.util.List; import java.util.Locale; import java.util.Objects; import java.util.stream.Collectors; /** * This class models the contents of a changelog YAML file. We validate it using a * JSON Schema, as well as some programmatic checks in {@link ValidateChangelogEntryTask}. * <ul>Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Wed Sep 01 06:25:29 GMT 2021 - 9.3K bytes - Click Count (0) -
internal/s3select/json/reader.go
return nil, io.EOF } var kvs jstream.KVS if v.ValueType == jstream.Object { // This is a JSON object type (that preserves key // order) kvs, _ = v.Value.(jstream.KVS) } else { // To be AWS S3 compatible Select for JSON needs to // output non-object JSON as single column value // i.e. a map with `_1` as key and value as the // non-object. kvs = jstream.KVS{jstream.KV{Key: "_1", Value: v.Value}} }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 3.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/hash/BloomFilterTest.java
import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.math.RoundingMode; import java.util.ArrayList; import java.util.List; import java.util.Random; import java.util.stream.Stream; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; import org.jspecify.annotations.Nullable; /** * Tests for SimpleGenericBloomFilter and derived BloomFilter views. *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 19 18:53:45 GMT 2026 - 23K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/helper/SystemHelperTest.java
import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Locale; import java.util.Map; import java.util.concurrent.atomic.AtomicReference; import java.util.stream.Collectors; import java.util.stream.Stream; import org.codelibs.core.io.FileUtil; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.misc.Pair; import org.codelibs.core.misc.Tuple3;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 44.4K bytes - Click Count (0) -
api/go1.4.txt
pkg compress/zlib, type Resetter interface { Reset } pkg compress/zlib, type Resetter interface, Reset(io.Reader, []uint8) error # CL 159120044 compress/gzip: allow stopping at end of first stream, Russ Cox <******@****.***> pkg compress/gzip, method (*Reader) Multistream(bool) # CL 138800043 crypto: Add SHA3 functions in go.crypto/sha3 to the Hash enum., David Leon Gil <******@****.***> pkg crypto, const SHA3_224 = 10Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Fri Dec 12 03:01:01 GMT 2014 - 34K bytes - Click Count (0) -
compat/maven-model/src/test/java/org/apache/maven/model/v4/ModelXmlTest.java
* KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. */ package org.apache.maven.model.v4; import javax.xml.stream.XMLStreamException; import java.io.IOException; import java.io.StringReader; import java.io.StringWriter; import java.util.LinkedHashMap; import java.util.Map; import org.apache.maven.api.model.Model;
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Wed Sep 17 10:01:14 GMT 2025 - 4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/scheduler/ApiAdminSchedulerAction.java
import static org.codelibs.fess.app.web.admin.scheduler.AdminSchedulerAction.getScheduledJob; import java.util.List; import java.util.Map; import java.util.UUID; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.Constants; import org.codelibs.fess.app.pager.SchedulerPager;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 11:55:54 GMT 2026 - 10.7K bytes - Click Count (0) -
docs/fr/docs/advanced/custom-response.md
Au lieu de renvoyer une `StreamingResponse` directement, vous devriez probablement suivre le style de [Diffuser des données](./stream-data.md), c'est beaucoup plus pratique et gère l'annulation en arrière-plan pour vous. Si vous diffusez des JSON Lines, suivez le didacticiel [Diffuser des JSON Lines](../tutorial/stream-json-lines.md). /// ### `FileResponse` { #fileresponse } Diffuse de façon asynchrone un fichier comme réponse.
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:37:13 GMT 2026 - 12.3K bytes - Click Count (0)