Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 1,283 for Chan (0.03 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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 {
        @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Aug 10 19:54:19 GMT 2025
    - 2.5K bytes
    - Click Count (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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 provided
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  10. 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)
Back to Top