Search Options

Results per page
Sort
Preferred Languages
Advance

Results 321 - 330 of 527 for channels (0.08 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top