- Sort Score
- Result 10 results
- Languages All
Results 201 - 210 of 621 for wantCS (0.07 sec)
-
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
*/ if (throwable instanceof Error) { /* * TODO(cpovirk): Do we really want to log this if we called setException(throwable) and it * returned true? This was intentional (CL 46470009), but it seems odd compared to how we * normally handle Error. * * Similarly, do we really want to log the same Error more than once? */ log(throwable); } }Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 16K bytes - Viewed (0) -
.github/workflows/scorecard.yml
with: results_file: results.sarif results_format: sarif # (Optional) "write" PAT token. Uncomment the `repo_token` line below if: # - you want to enable the Branch-Protection check on a *public* repository, or # - you are installing Scorecard on a *private* repositoryRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Dec 01 19:32:55 UTC 2025 - 2.9K bytes - Viewed (0) -
internal/ringbuffer/README.md
# Blocking vs Non-blocking The default behavior of the ring buffer is non-blocking, meaning that reads and writes will return immediately with an error if the operation cannot be completed. If you want to block when reading or writing, you must enable it: ```go rb := ringbuffer.New(1024).SetBlocking(true) ``` Enabling blocking will cause the ring buffer to behave like a buffered [io.Pipe](https://pkg.go.dev/io#Pipe).
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 2.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java
if (lastElementAt == index) { // 'actualLastElement' is now at 'lastElementAt', and the element that was at 'lastElementAt' // is now at the end of queue. If that's the element we wanted to remove in the first place, // don't try to (incorrectly) trickle it. Instead, just delete it and we're done. queue[size] = null; return null; } E toTrickle = elementData(size);
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 22 18:35:44 UTC 2025 - 33.9K bytes - Viewed (0) -
internal/grid/muxserver.go
func (m *muxServer) checkSeq(seq uint32) (ok bool) { if seq != m.RecvSeq { if debugPrint { fmt.Printf("expected sequence %d, got %d\n", m.RecvSeq, seq) } m.disconnect(fmt.Sprintf("receive sequence number mismatch. want %d, got %d", m.RecvSeq, seq), false) return false } m.RecvSeq++ return true } func (m *muxServer) message(msg message) { if debugPrint {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 9.7K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/ArtifactRepositoryMetadata.java
} @Override public String getArtifactId() { return artifact.getArtifactId(); } @Override public String getBaseVersion() { // Don't want the artifact's version in here, as this is stored in the directory above that return null; } @Override public Object getKey() {Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 3.6K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* </ul> * * <p>The main purpose of {@link #addListener addListener} is to support this chaining. You will * rarely use it directly, in part because it does not provide direct access to the {@code Future} * result. (If you want such access, you may prefer {@link Futures#addCallback * Futures.addCallback}.) Still, direct {@code addListener} calls are occasionally useful: * * {@snippet : * final String name = ...; * inFlight.add(name);Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenableFuture.java
* </ul> * * <p>The main purpose of {@link #addListener addListener} is to support this chaining. You will * rarely use it directly, in part because it does not provide direct access to the {@code Future} * result. (If you want such access, you may prefer {@link Futures#addCallback * Futures.addCallback}.) Still, direct {@code addListener} calls are occasionally useful: * * {@snippet : * final String name = ...; * inFlight.add(name);Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/ArtifactResolver.java
import org.apache.maven.artifact.repository.ArtifactRepository; import org.apache.maven.artifact.resolver.filter.ArtifactFilter; import org.apache.maven.wagon.events.TransferListener; /** */ // Just hide the one method we want behind the RepositorySystem interface. @Deprecated public interface ArtifactResolver { ArtifactResolutionResult resolve(ArtifactResolutionRequest request); // The rest is deprecatedRegistered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 5.1K bytes - Viewed (0) -
internal/grid/connection.go
} readDataInto := func(dst []byte, s ws.State, want ws.OpCode) ([]byte, error) { dst = dst[:0] for { hdr, err := wsReader.NextFrame() if err != nil { return nil, err } if hdr.OpCode.IsControl() { if err := controlHandler(hdr, &wsReader); err != nil { return nil, err } continue } if hdr.OpCode&want == 0 { if err := wsReader.Discard(); err != nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 46.9K bytes - Viewed (0)