- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 46 for IsStream (0.14 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)