- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 102 for isopen (0.16 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
/** * Returns true if this stream is open. A stream is open until either: * * * A `SYN_RESET` frame abnormally terminates the stream. * * Both input and output streams have transmitted all data and headers. * * Note that the input stream may continue to yield data even after a stream reports itself as * not open. This is because input data is buffered. */ val isOpen: Boolean get() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
} else { writePing(false, INTERVAL_PING, 0) return@schedule pingIntervalNanos } } } } /** * Returns the number of [open streams][Http2Stream.isOpen] on this connection. */ fun openStreamCount(): Int = this.withLock { streams.size } fun getStream(id: Int): Http2Stream? = this.withLock { streams[id] }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
func unstructureIstioType(spec any) (map[string]any, error) { b, err := yaml.Marshal(spec) if err != nil { return nil, err } iSpec := map[string]any{} err = yaml.Unmarshal(b, &iSpec) if err != nil { return nil, err } return iSpec, nil } func convertToUnsignedInt32Map(s []string) map[string]uint32 { out := make(map[string]uint32, len(s)) for _, l := range s {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 17 20:06:41 GMT 2024 - 25.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
.pingInterval(Duration.ofMillis(500)) .build() // Stall in onOpen to prevent pongs from being sent. val latch = CountDownLatch(1) webServer.enqueue( MockResponse.Builder() .webSocketUpgrade( object : WebSocketListener() { override fun onOpen( webSocket: WebSocket, response: Response, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
tensorflow/c/experimental/filesystem/plugins/posix/posix_filesystem.cc
TF_SetStatus(status, TF_OK, ""); } static void NewWritableFile(const TF_Filesystem* filesystem, const char* path, TF_WritableFile* file, TF_Status* status) { FILE* f = fopen(path, "w"); if (f == nullptr) { TF_SetStatusFromIOError(status, errno, path); return; } file->plugin_file = new tf_writable_file::PosixFile({strdup(path), f}); TF_SetStatus(status, TF_OK, "");
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Sun Mar 24 20:08:23 GMT 2024 - 15.8K bytes - Viewed (0) -
docs/de/docs/help-fastapi.md
Insbesondere: * <a href="https://github.com/tiangolo" class="external-link" target="_blank"> Folgen Sie mir auf **GitHub**</a>. * Finden Sie andere Open-Source-Projekte, die ich erstellt habe und die Ihnen helfen könnten. * Folgen Sie mir, um mitzubekommen, wenn ich ein neues Open-Source-Projekt erstelle.
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Sat Mar 30 20:29:57 GMT 2024 - 16K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/RangeTest.java
.addEqualityGroup(Range.greaterThan(1), Range.downTo(1, OPEN)) .addEqualityGroup(Range.atMost(7), Range.upTo(7, CLOSED)) .addEqualityGroup(Range.lessThan(7), Range.upTo(7, OPEN)) .addEqualityGroup(Range.open(1, 7), Range.range(1, OPEN, 7, OPEN)) .addEqualityGroup(Range.openClosed(1, 7), Range.range(1, OPEN, 7, CLOSED))
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 21 10:16:44 GMT 2024 - 24.1K bytes - Viewed (0) -
docs/en/docs/help-fastapi.md
You can: * <a href="https://github.com/tiangolo" class="external-link" target="_blank">Follow me on **GitHub**</a>. * See other Open Source projects I have created that could help you. * Follow me to see when I create a new Open Source project.
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 13.7K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
CommandShort: "Open admin web UI for a proxy", CommandLong: `Open the admin dashboard for a proxy, like envoy and ztunnel pods`, CommandExample: ` # Open envoy admin dashboard for the productpage-123-456.default pod istioctl dashboard proxy productpage-123-456.default # Open envoy admin dashboard for one pod under a deployment istioctl dashboard proxy deployment/productpage-v1
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/google/MultisetNavigationTester.java
expectAddFailure(sortedMultiset.tailMultiset(b.getElement(), OPEN), b); expectAddFailure(sortedMultiset.tailMultiset(c.getElement(), CLOSED), a); expectAddFailure(sortedMultiset.tailMultiset(c.getElement(), CLOSED), b); expectAddFailure(sortedMultiset.tailMultiset(c.getElement(), OPEN), a); expectAddFailure(sortedMultiset.tailMultiset(c.getElement(), OPEN), b);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 25.9K bytes - Viewed (0)