- Sort Score
- Num 10 results
- Language All
Results 71 - 80 of 1,283 for Chan (0.08 seconds)
-
guava/src/com/google/common/collect/SingletonImmutableList.java
import com.google.common.annotations.J2ktIncompatible; import com.google.common.base.Preconditions; import java.util.Spliterator; /** * Implementation of {@link ImmutableList} with exactly one element. * * @author Hayward Chan */ @GwtCompatible @SuppressWarnings("serial") // uses writeReplace(), not default serialization final class SingletonImmutableList<E> extends ImmutableList<E> { final transient E element;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Sep 22 21:07:18 GMT 2025 - 2.3K bytes - Click Count (0) -
src/bufio/net_test.go
} // Start a goroutine for the server to accept one connection // and read all the data sent on the connection, // reporting the number of bytes read on ch. ch := make(chan int, 1) var wg sync.WaitGroup wg.Add(1) go func() { defer wg.Done() tot := 0 defer func() { ch <- tot }() serverConn, err := server.Accept() if err != nil { t.Error(err)
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Fri Feb 07 19:37:07 GMT 2025 - 1.9K bytes - Click Count (0) -
cmd/storage-interface.go
// has never been replaced. Healing() *healingTracker DiskInfo(ctx context.Context, opts DiskInfoOptions) (info DiskInfo, err error) NSScanner(ctx context.Context, cache dataUsageCache, updates chan<- dataUsageEntry, scanMode madmin.HealScanMode, shouldSleep func() bool) (dataUsageCache, error) // Volume operations. MakeVol(ctx context.Context, volume string) (err error)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Apr 25 05:41:04 GMT 2025 - 5.3K bytes - Click Count (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/RegularImmutableMap.java
* limitations under the License. */ package com.google.common.collect; import java.util.Map; /** * GWt emulation of {@link RegularImmutableMap}. * * @author Hayward Chan */ final class RegularImmutableMap<K, V> extends ForwardingImmutableMap<K, V> { static final ImmutableMap<Object, Object> EMPTY = new RegularImmutableMap<Object, Object>();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 1.3K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/collect/testing/google/BiMapGenerators.java
import java.util.Map.Entry; import org.jspecify.annotations.NullMarked; /** * Generators of various {@link com.google.common.collect.BiMap}s and derived collections. * * @author Jared Levy * @author Hayward Chan */ @GwtCompatible @NullMarked public class BiMapGenerators { public static class ImmutableBiMapGenerator extends TestStringBiMapGenerator { @OverrideCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Aug 10 19:54:19 GMT 2025 - 2.5K bytes - Click Count (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableEnumMap.java
import java.util.Map; import java.util.Map.Entry; /** * GWT emulation of {@link ImmutableEnumMap}. The type parameter is not bounded by {@code Enum<E>} * to avoid code-size bloat. * * @author Hayward Chan */ final class ImmutableEnumMap<K, V> extends ForwardingImmutableMap<K, V> { static <K, V> ImmutableMap<K, V> asImmutable(Map<K, V> map) { for (Entry<K, V> entry : checkNotNull(map).entrySet()) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 1.3K bytes - Click Count (0) -
cmd/signals.go
"strings" "time" "github.com/coreos/go-systemd/v22/daemon" "github.com/minio/minio/internal/logger" ) func shutdownHealMRFWithTimeout() { const shutdownTimeout = time.Minute finished := make(chan struct{}) go func() { globalMRFState.shutdown() close(finished) }() select { case <-time.After(shutdownTimeout): case <-finished: } } func handleSignals() { // Custom exit function
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Sep 04 17:02:39 GMT 2024 - 3.2K bytes - Click Count (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ForwardingImmutableList.java
import java.util.Collection; import java.util.List; import org.jspecify.annotations.Nullable; /** * GWT emulated version of {@link ImmutableList}. TODO(cpovirk): more doc * * @author Hayward Chan */ abstract class ForwardingImmutableList<E> extends ImmutableList<E> { ForwardingImmutableList() {} abstract List<E> delegateList(); @Override public int indexOf(@Nullable Object object) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Aug 06 18:32:41 GMT 2025 - 2.5K bytes - Click Count (0) -
internal/s3select/jstream/decoder.go
// JSON values type Decoder struct { *scanner emitDepth int maxDepth int emitKV bool emitRecursive bool objectAsKVS bool depth int scratch *scratch metaCh chan *MetaValue err error // follow line position to add context to errors lineNo int lineStart int64 } // NewDecoder creates new Decoder to read JSON values at the providedCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 13.4K bytes - Click Count (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/SingletonImmutableBiMap.java
import static java.util.Collections.singletonMap; import org.jspecify.annotations.Nullable; /** * GWT emulation of {@link SingletonImmutableBiMap}. * * @author Hayward Chan */ final class SingletonImmutableBiMap<K, V> extends ImmutableBiMap<K, V> { private final K singleKey; private final V singleValue; @Nullable transient SingletonImmutableBiMap<V, K> inverse;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Jul 01 22:23:20 GMT 2025 - 1.8K bytes - Click Count (0)