Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1011 - 1020 of 1,261 for Stream (0.1 seconds)

  1. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/test/GradleDistroTestTask.java

            if (testClass != null) {
                line.append(" --tests=");
                line.append(testClass);
            }
            extraArgs.stream().map(s -> " " + s).forEach(line::append);
            return Collections.singletonList(line.toString());
        }
    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)
  2. 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;
    
        @Inject
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 10.6K bytes
    - Click Count (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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 = 10
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Dec 12 03:01:01 GMT 2014
    - 34K bytes
    - Click Count (0)
  8. 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)
  9. 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)
  10. 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)
Back to Top