Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 1,094 for Chan (0.04 sec)

  1. android/guava-testlib/src/com/google/common/collect/testing/testers/Platform.java

     */
    
    package com.google.common.collect.testing.testers;
    
    import com.google.common.annotations.GwtCompatible;
    import java.util.Locale;
    
    /**
     * This class is emulated in GWT.
     *
     * @author Hayward Chan
     */
    @GwtCompatible
    final class Platform {
    
      /** Format the template with args, only supports the placeholder {@code %s}. */
      static String format(String template, Object... args) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 1.3K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/collect/testing/google/BiMapGenerators.java

    import java.util.Map;
    import java.util.Map.Entry;
    
    /**
     * Generators of various {@link com.google.common.collect.BiMap}s and derived collections.
     *
     * @author Jared Levy
     * @author Hayward Chan
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    public class BiMapGenerators {
      public static class ImmutableBiMapGenerator extends TestStringBiMapGenerator {
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  3. cmd/consolelogger.go

    func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool {
    	return sys != nil && sys.pubsub.Subscribers() > 0
    }
    
    // Subscribe starts console logging for this node.
    func (sys *HTTPConsoleLoggerSys) Subscribe(subCh chan log.Info, doneCh <-chan struct{}, node string, last int, logKind madmin.LogMask, filter func(entry log.Info) bool) error {
    	// Enable console logging for remote client.
    	if !sys.HasLogListeners() {
    		logger.AddSystemTarget(GlobalContext, sys)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  4. cmd/data-scanner_test.go

    	globalBucketObjectLockSys = &BucketObjectLockSys{}
    	globalBucketVersioningSys = &BucketVersioningSys{}
    	es := newExpiryState(context.Background(), objAPI, 0)
    	workers := []chan expiryOp{make(chan expiryOp)}
    	es.workers.Store(&workers)
    	globalExpiryState = es
    	var wg sync.WaitGroup
    	wg.Add(1)
    	expired := make([]ObjectToDelete, 0, 5)
    	go func() {
    		defer wg.Done()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 03 11:18:58 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  5. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/SingletonImmutableList.java

    import static java.util.Collections.singletonList;
    
    import java.util.List;
    
    /**
     * GWT emulated version of {@link SingletonImmutableList}.
     *
     * @author Hayward Chan
     */
    @ElementTypesAreNonnullByDefault
    final class SingletonImmutableList<E> extends ForwardingImmutableList<E> {
    
      final transient List<E> delegate;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jan 23 18:43:40 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  6. android/guava-testlib/src/com/google/common/collect/testing/Platform.java

    import com.google.common.annotations.GwtCompatible;
    import java.util.Locale;
    
    /**
     * Methods factored out so that they can be emulated differently in GWT.
     *
     * <p>This class is emulated in GWT.
     *
     * @author Hayward Chan
     */
    @GwtCompatible
    final class Platform {
      static <T> T[] clone(T[] array) {
        return array.clone();
      }
    
      // Class.cast is not supported in GWT.  This method is a no-op in GWT.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Aug 04 01:39:13 UTC 2022
    - 1.3K bytes
    - Viewed (0)
  7. internal/event/target/nsq.go

    	initOnce once.Init
    
    	id         event.TargetID
    	args       NSQArgs
    	producer   *nsq.Producer
    	store      store.Store[event.Event]
    	config     *nsq.Config
    	loggerOnce logger.LogOnce
    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *NSQTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *NSQTarget) Name() string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/collect/ForwardingMultimapTest.java

    import com.google.common.testing.EqualsTester;
    import com.google.common.testing.ForwardingWrapperTester;
    import junit.framework.TestCase;
    
    /**
     * Unit test for {@link ForwardingMultimap}.
     *
     * @author Hayward Chan
     */
    public class ForwardingMultimapTest extends TestCase {
    
      @SuppressWarnings("rawtypes")
      public void testForwarding() {
        new ForwardingWrapperTester()
            .testForwarding(
                Multimap.class,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 20:09:59 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  9. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 04 17:02:39 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  10. guava-gwt/test-super/com/google/common/collect/testing/super/com/google/common/collect/testing/Platform.java

    import java.util.Arrays;
    
    /**
     * Minimal GWT emulation of {@code com.google.common.collect.testing.Platform}.
     *
     * <p><strong>This .java file should never be consumed by javac.</strong>
     *
     * @author Hayward Chan
     */
    final class Platform {
      // Class.cast is not supported in GWT.
      static void checkCast(Class<?> clazz, Object obj) {}
    
      static <T> T[] clone(T[] array) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 2.1K bytes
    - Viewed (0)
Back to top