Search Options

Results per page
Sort
Preferred Languages
Advance

Results 371 - 380 of 770 for channel (0.04 sec)

  1. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

       * one or more such elements. Returns {@code true} if this queue contained the specified element
       * (or equivalently, if this queue changed as a result of the call).
       *
       * @param o element to be removed from this queue, if present
       * @return {@code true} if this queue changed as a result of the call
       */
      @CanIgnoreReturnValue
      @Override
      public boolean remove(@Nullable Object o) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  2. .github/labels.json

        },
        "tested": {
          "name": "type:tested",
          "colour": "#00ff00",
          "description": "tested"
        },
        "breaking_change": {
          "name": "type:breaking change",
          "colour": "#CF2E1F",
          "description": "breaking change"
        }
      },
      "issue": {
        "with_playground": {
          "requires": 1,
          "conditions": [
            {
              "type": "descriptionMatches",
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Mon Oct 19 03:49:03 UTC 2020
    - 3.8K bytes
    - Viewed (0)
  3. src/main/java/jcifs/internal/smb1/com/SmbComSeek.java

    import jcifs.internal.SMBProtocolDecodingException;
    import jcifs.internal.smb1.ServerMessageBlock;
    import jcifs.internal.util.SMBUtil;
    
    /**
     * SMB1 COM_SEEK command implementation.
     *
     * This command changes the current file position pointer for a file.
     * It allows seeking to different positions within an open file.
     *
     * @author mbechler
     */
    public class SmbComSeek extends ServerMessageBlock {
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  4. CODE_OF_CONDUCT.md

    interaction with the people involved, including unsolicited interaction with
    those enforcing the Code of Conduct, for a specified period. This
    includes avoiding interactions in community spaces and external channels
    like social media. Violating these terms may lead to a temporary or
    permanent ban.
    
    ### 3. Temporary Ban
    
    **Community Impact**: A serious violation of community standards, including
    sustained inappropriate behavior.
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Thu Oct 17 06:18:13 UTC 2024
    - 5K bytes
    - Viewed (0)
  5. .github/workflows/go-healing.yml

    on:
      pull_request:
        branches:
          - master
    
    # This ensures that previous jobs for the PR are canceled when the PR is
    # updated.
    concurrency:
      group: ${{ github.workflow }}-${{ github.head_ref }}
      cancel-in-progress: true
    
    permissions:
      contents: read
    
    jobs:
      build:
        name: Go ${{ matrix.go-version }} on ${{ matrix.os }}
        runs-on: ${{ matrix.os }}
        strategy:
          matrix:
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 1.2K bytes
    - Viewed (0)
  6. tests/multi_primary_keys_test.go

    		t.Fatalf("CN Blog's tags should not be changed after EN Blog Replace")
    	}
    
    	var blog11 Blog
    	DB.Preload("LocaleTags").First(&blog11, "id = ? AND locale = ?", blog.ID, blog.Locale)
    	if !compareTags(blog11.LocaleTags, []string{"tag1", "tag2", "tag3"}) {
    		t.Fatalf("CN Blog's tags should not be changed after EN Blog Replace")
    	}
    
    	DB.Model(&blog2).Association("LocaleTags").Find(&tags2)
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Mon Jul 21 02:46:58 UTC 2025
    - 13.1K bytes
    - Viewed (0)
  7. .github/workflows/go.yml

    on:
      pull_request:
        branches:
          - master
    
    # This ensures that previous jobs for the PR are canceled when the PR is
    # updated.
    concurrency:
      group: ${{ github.workflow }}-${{ github.head_ref }}
      cancel-in-progress: true
    
    permissions:
      contents: read
    
    jobs:
      build:
        name: Go ${{ matrix.go-version }} on ${{ matrix.os }} - healing
        runs-on: ${{ matrix.os }}
        strategy:
          matrix:
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 1.1K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt

              webSocketCloseTimeout,
            ).apply {
              if (client) {
                call =
                  object : FailingCall() {
                    override fun cancel() {
                      this@TestStreams.cancel()
                    }
                  }
              }
            }
          webSocket!!.initReaderAndWriter(name, this, client)
        }
    
        /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 18.7K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

       * of {@link CombinedFuture}, the user-supplied callback usually has its own references to inputs.
       */
      /*
       * In certain circumstances, this field might theoretically not be visible to an afterDone() call
       * triggered by cancel(). For details, see the comments on the fields of TimeoutFuture.
       */
      @LazyInit
      private @Nullable ImmutableCollection<? extends ListenableFuture<? extends InputT>> futures;
    
      private final boolean allMustSucceed;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 16K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

          // code should be unreachable with correctly implemented Futures.
          // Cancel this future and return.
          // At this point, inputFuture is cancelled and outputFuture doesn't exist, so the value of
          // mayInterruptIfRunning is irrelevant.
          cancel(false);
          return;
        } catch (ExecutionException e) {
          // Set the cause of the exception as this future's exception.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Feb 20 18:03:37 UTC 2025
    - 10.8K bytes
    - Viewed (0)
Back to top