Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 1,096 for Chan (0.14 sec)

  1. src/cmd/api/testdata/src/pkg/p1/p1.go

    	return now
    }
    
    var x = &S{
    	Public:     nil,
    	private:    nil,
    	PublicTime: Now(),
    }
    
    var parenExpr = (1 + 5)
    
    var funcLit = func() {}
    
    var m map[string]int
    
    var chanVar chan int
    
    var ifaceVar any = 5
    
    var assertVar = ifaceVar.(int)
    
    var indexVar = m["foo"]
    
    var Byte byte
    var ByteFunc func(byte) rune
    
    type ByteStruct struct {
    	B byte
    	R rune
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Dec 02 16:29:41 GMT 2022
    - 3.3K bytes
    - Viewed (0)
  2. cmd/iam-object-store.go

    // items have the pathPrefix removed from their names.
    func listIAMConfigItems(ctx context.Context, objAPI ObjectLayer, pathPrefix string) <-chan itemOrErr {
    	ch := make(chan itemOrErr)
    
    	go func() {
    		defer xioutil.SafeClose(ch)
    
    		// Allocate new results channel to receive ObjectInfo.
    		objInfoCh := make(chan ObjectInfo)
    
    		if err := objAPI.Walk(ctx, minioMetaBucket, pathPrefix, objInfoCh, WalkOptions{}); err != nil {
    			select {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 05 21:26:41 GMT 2024
    - 19.9K bytes
    - Viewed (0)
  3. internal/event/target/elasticsearch.go

    type ElasticsearchTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       ElasticsearchArgs
    	client     esClient
    	store      store.Store[event.Event]
    	loggerOnce logger.LogOnce
    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *ElasticsearchTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 15K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/Platform.java

    import java.util.Map;
    import java.util.Set;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Methods factored out so that they can be emulated differently in GWT.
     *
     * @author Hayward Chan
     */
    @GwtCompatible(emulated = true)
    @ElementTypesAreNonnullByDefault
    final class Platform {
      /** Returns the platform preferred implementation of a map based on a hash table. */
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 21:19:52 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  5. cmd/data-usage.go

    	dataUsageCacheName = ".usage-cache.bin"
    )
    
    // storeDataUsageInBackend will store all objects sent on the dui channel until closed.
    func storeDataUsageInBackend(ctx context.Context, objAPI ObjectLayer, dui <-chan DataUsageInfo) {
    	attempts := 1
    	for dataUsageInfo := range dui {
    		json := jsoniter.ConfigCompatibleWithStandardLibrary
    		dataUsageJSON, err := json.Marshal(dataUsageInfo)
    		if err != nil {
    			scannerLogIf(ctx, err)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  6. cmd/admin-heal-ops.go

    	settings madmin.HealOpts
    
    	// current accumulated status of the heal sequence
    	currentStatus healSequenceStatus
    
    	// channel signaled by background routine when traversal has
    	// completed
    	traverseAndHealDoneCh chan error
    
    	// canceler to cancel heal sequence.
    	cancelCtx context.CancelFunc
    
    	// the last result index sent to client
    	lastSentResultIndex int64
    
    	// Number of total items scanned against item type
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  7. guava-testlib/src/com/google/common/collect/testing/google/SortedMapGenerators.java

    import java.util.Map.Entry;
    import java.util.SortedMap;
    
    /**
     * Generators of sorted maps and derived collections.
     *
     * @author Kevin Bourrillion
     * @author Jesse Wilson
     * @author Jared Levy
     * @author Hayward Chan
     * @author Chris Povirk
     * @author Louis Wasserman
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    public class SortedMapGenerators {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Feb 26 19:46:10 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  8. src/builtin/builtin.go

    // constant. See the Go language specification's "Length and capacity" section for
    // details.
    func cap(v Type) int
    
    // The make built-in function allocates and initializes an object of type
    // slice, map, or chan (only). Like new, the first argument is a type, not a
    // value. Unlike new, make's return type is the same as the type of its
    // argument, not a pointer to it. The specification of the result depends on
    // the type:
    //
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Thu Apr 11 20:22:45 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  9. doc/go1.17_spec.html

    &lt;-chan &lt;-chan int  // same as &lt;-chan (&lt;-chan int)
    chan (&lt;-chan int)
    </pre>
    
    <p>
    A new, initialized channel
    value can be made using the built-in function
    <a href="#Making_slices_maps_and_channels"><code>make</code></a>,
    which takes the channel type and an optional <i>capacity</i> as arguments:
    </p>
    
    <pre>
    make(chan int, 100)
    </pre>
    
    <p>
    HTML
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Thu Apr 11 20:22:45 GMT 2024
    - 211.6K bytes
    - Viewed (0)
  10. internal/dsync/drwmutex.go

    // GetLock tries to get a write lock on dm before the timeout elapses.
    //
    // If the lock is already in use, the calling go routine
    // blocks until either the mutex becomes available and return success or
    // more time has passed than the timeout value and return false.
    func (dm *DRWMutex) GetLock(ctx context.Context, cancel context.CancelFunc, id, source string, opts Options) (locked bool) {
    	isReadLock := false
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 19.7K bytes
    - Viewed (0)
Back to top