- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 1,094 for Chan (0.04 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)