Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 46 for IsStream (0.14 sec)

  1. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

        assertThat(URLConnection.getDefaultRequestProperty("X-setDefaultRequestProperty")).isNull()
      }
    
      /**
       * Reads `count` characters from the stream. If the stream is exhausted before `count`
       * characters can be read, the remaining characters are returned and the stream is closed.
       */
      private fun readAscii(
        inputStream: InputStream,
        count: Int,
      ): String {
        val result = StringBuilder()
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 131.7K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/Maps.java

    import java.util.SortedSet;
    import java.util.TreeMap;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentMap;
    import java.util.function.BinaryOperator;
    import java.util.stream.Collector;
    import javax.annotation.CheckForNull;
    import org.checkerframework.checker.nullness.qual.NonNull;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Sun Jun 02 13:36:19 UTC 2024
    - 159.5K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/Maps.java

    import java.util.concurrent.ConcurrentMap;
    import java.util.function.BiConsumer;
    import java.util.function.BiFunction;
    import java.util.function.BinaryOperator;
    import java.util.function.Consumer;
    import java.util.stream.Collector;
    import javax.annotation.CheckForNull;
    import org.checkerframework.checker.nullness.qual.NonNull;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Apr 24 19:38:27 UTC 2024
    - 165.9K bytes
    - Viewed (0)
  4. src/net/http/transport_test.go

    		// requests don't race with the call to SetRSTAvoidanceDelay for a retry.
    		defer cst.close()
    		ts := cst.ts
    		c := ts.Client()
    
    		res, err := c.Post(ts.URL, "application/octet-stream", neverEnding('a'))
    		if err != nil {
    			return fmt.Errorf("Post: %v", err)
    		}
    		got, err := io.ReadAll(res.Body)
    		if err != nil {
    			return fmt.Errorf("Body ReadAll: %v", err)
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 192.6K bytes
    - Viewed (0)
  5. src/net/http/serve_test.go

    	}
    	r, err = c.Do(req)
    	if err == nil {
    		r.Body.Close()
    		return fmt.Errorf("Get #2 expected error, got nil")
    	}
    	if mode == http2Mode {
    		expected := "stream ID 3; INTERNAL_ERROR" // client IDs are odd, second stream should be 3
    		if !strings.Contains(err.Error(), expected) {
    			return fmt.Errorf("http2 Get #2: expected error to contain %q, got %q", expected, err)
    		}
    	}
    	return nil
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 202K bytes
    - Viewed (0)
  6. src/cmd/internal/obj/ppc64/asm9.go

    	case 43: /* data cache instructions: op (Ra+[Rb]), [th|l] */
    		/* TH field for dcbt/dcbtst: */
    		/* 0 = Block access - program will soon access EA. */
    		/* 8-15 = Stream access - sequence of access (data stream). See section 4.3.2 of the ISA for details. */
    		/* 16 = Block access - program will soon make a transient access to EA. */
    		/* 17 = Block access - program will not access EA for a long time. */
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 13:55:28 UTC 2024
    - 156.1K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

       *       {@link #withoutCloser(AsyncFunction)}
       * </ul>
       *
       * <p>Example usage:
       *
       * <pre>{@code
       * // Fall back to a secondary input stream in case of IOException.
       * ClosingFuture<InputStream> inputFuture =
       *     firstInputFuture.catchingAsync(
       *         IOException.class, (closer, x) -> secondaryInputStreamClosingFuture(), executor);
       * }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 07 12:37:15 UTC 2024
    - 98.3K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/ClosingFuture.java

       *       {@link #withoutCloser(AsyncFunction)}
       * </ul>
       *
       * <p>Example usage:
       *
       * <pre>{@code
       * // Fall back to a secondary input stream in case of IOException.
       * ClosingFuture<InputStream> inputFuture =
       *     firstInputFuture.catchingAsync(
       *         IOException.class, (closer, x) -> secondaryInputStreamClosingFuture(), executor);
       * }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 98.7K bytes
    - Viewed (0)
  9. okhttp/src/test/resources/okhttp3/internal/publicsuffix/public_suffix_list.dat

    stcgroup
    
    // stockholm : 2014-12-18 Stockholms kommun
    stockholm
    
    // storage : 2014-12-22 XYZ.COM LLC
    storage
    
    // store : 2015-04-09 Radix FZC
    store
    
    // stream : 2016-01-08 dot Stream Limited
    stream
    
    // studio : 2015-02-11 Dog Beach, LLC
    studio
    
    // study : 2014-12-11 Registry Services, LLC
    study
    
    // style : 2014-12-04 Binky Moon, LLC
    style
    
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 240.3K bytes
    - Viewed (0)
  10. pkg/config/validation/validation.go

    		// https://www.envoyproxy.io/docs/envoy/latest/configuration/http/http_filters/router_filter.html#x-envoy-retry-on
    		"5xx",
    		"gateway-error",
    		"reset",
    		"connect-failure",
    		"retriable-4xx",
    		"refused-stream",
    		"retriable-status-codes",
    		"retriable-headers",
    		"envoy-ratelimited",
    		"http3-post-connect-failure",
    
    		// 'x-envoy-retry-grpc-on' supported policies:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 04:03:33 UTC 2024
    - 107.2K bytes
    - Viewed (0)
Back to top