Search Options

Results per page
Sort
Preferred Languages
Advance

Results 601 - 610 of 849 for upstream (0.12 sec)

  1. android/guava/src/com/google/common/hash/Funnel.java

     * @since 11.0
     */
    @Beta
    @DoNotMock("Implement with a lambda")
    @ElementTypesAreNonnullByDefault
    public interface Funnel<T extends @Nullable Object> extends Serializable {
    
      /**
       * Sends a stream of data from the {@code from} object into the sink {@code into}. There is no
       * requirement that this data be complete enough to fully reconstitute the object later.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 20 18:43:59 UTC 2021
    - 2.2K bytes
    - Viewed (0)
  2. okcurl/src/main/kotlin/okhttp3/curl/internal/-MainCommon.kt

        if (showHeaders) {
          println(StatusLine.get(response))
          val headers = response.headers
          for ((name, value) in headers) {
            println("$name: $value")
          }
          println()
        }
    
        // Stream the response to the System.out as it is returned from the server.
        val out = System.out.sink()
        val source = response.body.source()
        while (!source.exhausted()) {
          out.write(source.buffer, source.buffer.size)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  3. src/test/java/org/codelibs/core/io/PropertiesUtilTest.java

            /**
             *
             */
            private static final long serialVersionUID = 1L;
    
            @Override
            public synchronized void load(final InputStream inStream) throws IOException {
                throw new IOException("load");
            }
    
        }
    
        /**
         * {@link org.codelibs.core.io.PropertiesUtil#load(Properties, String)}
         */
        @Test
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  4. cmd/metacache-server-pool.go

    	o.SetFilter()
    	if o.Transient {
    		o.Create = false
    	}
    
    	// We have 2 cases:
    	// 1) Cold listing, just list.
    	// 2) Returning, but with no id. Start async listing.
    	// 3) Returning, with ID, stream from list.
    	//
    	// If we don't have a list id we must ask the server if it has a cache or create a new.
    	if o.ID != "" && !o.Transient {
    		// Create or ping with handout...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/ImmutableBiMap.java

    import java.util.Arrays;
    import java.util.Collection;
    import java.util.Comparator;
    import java.util.Map;
    import java.util.function.BinaryOperator;
    import java.util.function.Function;
    import java.util.stream.Collector;
    import java.util.stream.Collectors;
    import javax.annotation.CheckForNull;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/web/admin/upgrade/AdminUpgradeAction.java

    import java.io.IOException;
    import java.util.List;
    import java.util.Map;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.stream.StreamUtil;
    import org.codelibs.curl.CurlResponse;
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.annotation.Secured;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 01:54:46 UTC 2024
    - 54K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/query/DefaultQueryBuilder.java

     */
    package org.codelibs.fess.query;
    
    import java.io.IOException;
    import java.util.Objects;
    
    import org.apache.lucene.search.Query;
    import org.opensearch.core.common.io.stream.StreamOutput;
    import org.opensearch.core.xcontent.XContentBuilder;
    import org.opensearch.index.query.BoolQueryBuilder;
    import org.opensearch.index.query.DisMaxQueryBuilder;
    import org.opensearch.index.query.QueryBuilder;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/thumbnail/impl/HtmlTagBasedGeneratorTest.java

     */
    package org.codelibs.fess.thumbnail.impl;
    
    import java.awt.image.BufferedImage;
    import java.io.File;
    import java.io.IOException;
    
    import javax.imageio.ImageIO;
    import javax.imageio.stream.ImageInputStream;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.fess.unit.UnitFessTestCase;
    
    public class HtmlTagBasedGeneratorTest extends UnitFessTestCase {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  9. internal/s3select/jstream/scanner_test.go

    package jstream
    
    import (
    	"bufio"
    	"bytes"
    	"fmt"
    	"io"
    	"sync/atomic"
    	"testing"
    )
    
    var (
    	smallInput  = make([]byte, 1024*12)       // 12K
    	mediumInput = make([]byte, 1024*1024*12)  // 12MB
    	largeInput  = make([]byte, 1024*1024*128) // 128MB
    )
    
    func TestScanner(t *testing.T) {
    	data := []byte("abcdefghijklmnopqrstuvwxyz0123456789")
    
    	var i int
    	r := bytes.NewReader(data)
    	scanner := newScanner(r)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  10. docs/pt/docs/advanced/custom-response.md

    # Resposta Personalizada - HTML, Stream, File e outras
    
    Por padrão, o **FastAPI** irá retornar respostas utilizando `JSONResponse`.
    
    Mas você pode sobrescrever esse comportamento utilizando `Response` diretamente, como visto em [Retornando uma Resposta Diretamente](response-directly.md){.internal-link target=_blank}.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Oct 29 11:47:10 UTC 2024
    - 13.5K bytes
    - Viewed (0)
Back to top