- Sort Score
- Result 10 results
- Languages All
Results 371 - 380 of 770 for channel (0.04 sec)
-
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) -
.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) -
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) -
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) -
.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) -
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) -
.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) -
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) -
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) -
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)