- Sort Score
- Result 10 results
- Languages All
Results 321 - 330 of 527 for channels (0.08 sec)
-
guava/src/com/google/common/graph/StandardValueGraph.java
* AbstractGraphBuilder}. * * <p>This class maintains a map of nodes to {@link GraphConnections}. * * <p>Collection-returning accessors return unmodifiable views: the view returned will reflect * changes to the graph (if the graph is mutable) but may not be modified by the user. * * <p>The time complexity of all collection-returning accessors is O(1), since views are returned. * * @author James Sexton
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jan 22 17:29:38 UTC 2024 - 6.1K bytes - Viewed (0) -
guava/src/com/google/common/collect/MinMaxPriorityQueue.java
queue[size] = null; return null; } E toTrickle = elementData(size); queue[size] = null; MoveDesc<E> changes = fillHole(index, toTrickle); if (lastElementAt < index) { // Last element is moved to before index, swapped with trickled element. if (changes == null) { // The trickled element is still after index. return new MoveDesc<>(actualLastElement, toTrickle); } else {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 34.1K bytes - Viewed (0) -
docs/ja/docs/contributing.md
```console $ python ./scripts/docs.py live <span style="color: green;">[INFO]</span> Serving on http://127.0.0.1:8008 <span style="color: green;">[INFO]</span> Start watching changes <span style="color: green;">[INFO]</span> Start detecting changes ``` </div> ドキュメントは、`http://127.0.0.1:8008`で提供します。 そうすることで、ドキュメント/ソースファイルを編集し、変更をライブで見ることができます。 #### Typer CLI (任意)
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Aug 06 04:48:30 UTC 2024 - 16.6K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
Example: ` # Verify that Istio can be installed or upgraded istioctl x precheck # Check only a single namespace istioctl x precheck --namespace default # Check for behavioral changes since a specific version istioctl x precheck --from-version 1.10`, RunE: func(cmd *cobra.Command, args []string) (err error) { msgs := diag.Messages{} if !skipControlPlane { msgs, err = checkControlPlane(ctx)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Oct 24 02:31:32 UTC 2024 - 15.3K bytes - Viewed (0) -
architecture/networking/controllers.md
* Simple object filtering. Beyond just static filters on objects, `kclient` supports _dynamic filters_ that can change at runtime. When a filter changes and includes/removes new objects, those are automatically handled. * Proper syncing and shutdown logic. Checking for when an informer has fully started can be quite tricky; `kclient` automatically handles it.
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Feb 09 17:41:25 UTC 2024 - 4.9K bytes - Viewed (0) -
guava/src/com/google/common/collect/Collections2.java
public final class Collections2 { private Collections2() {} /** * Returns the elements of {@code unfiltered} that satisfy a predicate. The returned collection is * a live view of {@code unfiltered}; changes to one affect the other. * * <p>The resulting collection's iterator does not support {@code remove()}, but all other * collection methods are supported. When given an element that doesn't satisfy the predicate, the
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 20:24:49 UTC 2024 - 23.1K bytes - Viewed (0) -
internal/etag/reader.go
return n, VerifyError{ Expected: r.checksum, Computed: etag, } } } return n, err } // ETag returns the ETag of all the content read // so far. Reading more content changes the MD5 // checksum. Therefore, calling ETag multiple // times may return different results. func (r *Reader) ETag() ETag { sum := r.md5.Sum(nil) return ETag(sum) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 4.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
assertEvents( "R0.00, R1.38, R1.13, R0.88, R0.63, R0.50, R0.50, R0.50", // #1 "U4.50", // #2 "R0.00, R1.38, R1.13", // #3, after that the rate changes "R0.88", // #4, this is what the throttling would be with the old rate "R0.34, R0.28, R0.25, R0.25", // #5 "U4.25", // #6 "R0.00, R0.72, R0.66, R0.59, R0.53, R0.47, R0.41", // #7
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 14:28:19 UTC 2024 - 21.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
assertEvents( "R0.00, R1.38, R1.13, R0.88, R0.63, R0.50, R0.50, R0.50", // #1 "U4.50", // #2 "R0.00, R1.38, R1.13", // #3, after that the rate changes "R0.88", // #4, this is what the throttling would be with the old rate "R0.34, R0.28, R0.25, R0.25", // #5 "U4.25", // #6 "R0.00, R0.72, R0.66, R0.59, R0.53, R0.47, R0.41", // #7
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 14:28:19 UTC 2024 - 21.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
) } override fun connectTcp(): ConnectResult { check(rawSocket == null) { "TCP already connected" } var success = false // Tell the call about the connecting call so async cancels work. user.addPlanToCancel(this) try { user.connectStart(route) connectSocket() success = true return ConnectResult(plan = this) } catch (e: IOException) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 18.6K bytes - Viewed (0)