- Sort Score
- Num 10 results
- Language All
Results 571 - 580 of 596 for Handler (0.05 seconds)
-
android/guava-tests/test/com/google/common/collect/OrderingTest.java
Ordering<Integer> unusedE = integers.compound(numbers); // This works with three levels too (IDEA falsely reports errors as noted // below. Both javac and eclipse handle these cases correctly.) Ordering<Number> unusedF = numbers.compound(objects).compound(objects); // bad IDEA Ordering<Number> unusedG = objects.compound(numbers).compound(objects);
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Oct 10 23:13:45 GMT 2025 - 42.8K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/CompactHashMap.java
} /** Returns whether arrays need to be allocated. */ boolean needsAllocArrays() { return table == null; } /** Handle lazy allocation of arrays. */ @CanIgnoreReturnValue int allocArrays() { Preconditions.checkState(needsAllocArrays(), "Arrays already allocated"); int expectedSize = metadata;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 35.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/OrderingTest.java
Ordering<Integer> unusedE = integers.compound(numbers); // This works with three levels too (IDEA falsely reports errors as noted // below. Both javac and eclipse handle these cases correctly.) Ordering<Number> unusedF = numbers.compound(objects).compound(objects); // bad IDEA Ordering<Number> unusedG = objects.compound(numbers).compound(objects);
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Oct 10 23:13:45 GMT 2025 - 42.8K bytes - Click Count (0) -
guava/src/com/google/common/io/Files.java
* @param file the file to read from * @param charset the charset used to decode the input stream; see {@link StandardCharsets} for * helpful predefined constants * @param callback the {@link LineProcessor} to use to handle the lines * @return the output of processing the lines * @throws IOException if an I/O error occurs * @deprecated Prefer {@code asCharSource(file, charset).readLines(callback)}. */ @DeprecatedCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Sep 25 20:24:13 GMT 2025 - 32.8K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/Synchronized.java
// The SynchronizedObject subclasses don't need a writeObject method since // they don't contain any non-transient member variables, while the // following writeObject() handles the SynchronizedObject members. @GwtIncompatible @J2ktIncompatible private void writeObject(ObjectOutputStream stream) throws IOException { synchronized (mutex) {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Aug 08 15:11:10 GMT 2025 - 53K bytes - Click Count (0) -
guava/src/com/google/common/collect/Synchronized.java
// The SynchronizedObject subclasses don't need a writeObject method since // they don't contain any non-transient member variables, while the // following writeObject() handles the SynchronizedObject members. @GwtIncompatible @J2ktIncompatible private void writeObject(ObjectOutputStream stream) throws IOException { synchronized (mutex) {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Aug 08 15:11:10 GMT 2025 - 56.9K bytes - Click Count (0) -
src/cmd/asm/internal/asm/parse.go
// ARM only. if !p.arch.InFamily(sys.ARM, sys.ARM64) { return false } // R1<<... if lex.IsRegisterShift(p.peek()) { return true } // R(1)<<... Ugly check. TODO: Rethink how we handle ARM register shifts to be // less special. if p.peek() != '(' || len(p.input)-p.inputPos < 4 { return false } return p.at('(', scanner.Int, ')') && lex.IsRegisterShift(p.input[p.inputPos+3].ScanToken) }
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Wed Nov 12 03:59:40 GMT 2025 - 37.3K bytes - Click Count (0) -
cmd/notification.go
ctx := logger.SetReqInfo(ctx, reqInfo) peersLogOnceIf(ctx, err, client.host.String()) return nil } for typ, data := range data { // zip writer only handles one concurrent write writeMu.Lock() profilingDataFound = true err := embedFileInZip(zipWriter, fmt.Sprintf("profile-%s-%s", client.host.String(), typ), data, 0o600) writeMu.Unlock() if err != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 46K bytes - Click Count (0) -
internal/config/config.go
defKVS, ok := DefaultKVS[subSys] if !ok { return value, cs, isRedacted } defValue, isFound := defKVS.Lookup(cfgParam) // Comments usually are absent from `defKVS`, so we handle it specially. if !isFound && cfgParam == Comment { defValue, isFound = "", true } if !isFound { return value, cs, isRedacted } if target == "" { target = Default }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 37.7K bytes - Click Count (0) -
docs/bucket/notifications/README.md
log.Println("Connected") // Subscribe to subject log.Printf("Subscribing to subject 'bucketevents'\n") natsConnection.Subscribe("bucketevents", func(msg *nats.Msg) { // Handle the message log.Printf("Received message '%s\n", string(msg.Data)+"'") }) // Keep the connection alive runtime.Goexit() } ``` ``` go run nats.go 2016/10/12 06:39:18 Connected
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 84.2K bytes - Click Count (0)