- Sort Score
- Result 10 results
- Languages All
Results 11 - 15 of 15 for QueueSize (0.15 sec)
-
okhttp/src/main/kotlin/okhttp3/WebSocket.kt
* queue. If may return a nonzero value after the web socket has been canceled; this indicates * that enqueued messages were not transmitted. */ fun queueSize(): Long /** * Attempts to enqueue `text` to be UTF-8 encoded and sent as a the data of a text (type `0x1`) * message. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.3K bytes - Viewed (0) -
internal/grid/connection.go
continue } } if len(queue) < maxMergeMessages && queueSize+len(toSend) < writeBufferSize-1024 && len(c.outQueue) > 0 { queue = append(queue, toSend) queueSize += len(toSend) continue } c.outMessages.Add(int64(len(queue) + 1)) if c.outgoingBytes != nil { c.outgoingBytes(int64(len(toSend) + queueSize)) } c.connChange.L.Lock() for { state := c.State()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 46.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/shape_inference.cc
func::FuncOp ret = queue_.front(); queue_.pop(); queue_set_.erase(ret); return ret; } // Returns the current size of the queue. std::queue<func::FuncOp>::size_type QueueSize() const { return queue_.size(); } Dialect* const tf_dialect_; private: // Returns whether the result of an operation could be updated to a new
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Jun 08 07:28:49 UTC 2024 - 134.1K bytes - Viewed (0) -
okhttp/api/okhttp.api
} public abstract interface class okhttp3/WebSocket { public abstract fun cancel ()V public abstract fun close (ILjava/lang/String;)Z public abstract fun queueSize ()J public abstract fun request ()Lokhttp3/Request; public abstract fun send (Ljava/lang/String;)Z public abstract fun send (Lokio/ByteString;)Z }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 15 13:41:01 UTC 2024 - 70.2K bytes - Viewed (0)