Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 277 for mkchan (0.05 sec)

  1. doc/go1.17_spec.html

    <-chan <-chan int  // same as <-chan (<-chan int)
    chan (<-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>
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 10 18:25:45 UTC 2024
    - 211.6K bytes
    - Viewed (0)
  2. cmd/globals.go

    	globalIsTLS bool
    
    	globalTLSCerts *certs.Manager
    
    	globalHTTPServer        *xhttp.Server
    	globalTCPOptions        xhttp.TCPOptions
    	globalHTTPServerErrorCh = make(chan error)
    	globalOSSignalCh        = make(chan os.Signal, 1)
    
    	// global Trace system to send HTTP request/response
    	// and Storage/OS calls info to registered listeners.
    	globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (1)
  3. android/guava/src/com/google/common/annotations/GwtCompatible.java

     * to return a value with a GWT serializable type.
     *
     * <p>Note that a {@code GwtCompatible} type may have some {@link GwtIncompatible} methods.
     *
     * @author Charles Fry
     * @author Hayward Chan
     */
    @Retention(RetentionPolicy.CLASS)
    @Target({ElementType.TYPE, ElementType.METHOD})
    @Documented
    @GwtCompatible
    public @interface GwtCompatible {
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Dec 16 19:54:45 UTC 2020
    - 2.9K bytes
    - Viewed (0)
  4. tests/prepared_stmt_test.go

    	if !ok {
    		t.Fatalf("should assign PreparedStatement Manager back to database when using PrepareStmt mode")
    	}
    
    	loopCount := 100
    	var wg sync.WaitGroup
    	var unexpectedError bool
    	writerFinish := make(chan struct{})
    
    	wg.Add(1)
    	go func(id uint) {
    		defer wg.Done()
    		defer close(writerFinish)
    
    		for j := 0; j < loopCount; j++ {
    			var tmp User
    			err := tx.Session(&gorm.Session{}).First(&tmp, id).Error
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  5. cmd/metrics-resource.go

    func (c *minioResourceCollector) Describe(ch chan<- *prometheus.Desc) {
    	ch <- c.desc
    }
    
    // Collect is called by the Prometheus registry when collecting metrics.
    func (c *minioResourceCollector) Collect(out chan<- prometheus.Metric) {
    	var wg sync.WaitGroup
    	publish := func(in <-chan MetricV2) {
    		defer wg.Done()
    		for metric := range in {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 23:30:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  6. 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 {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  7. internal/s3select/json/reader.go

    const maxDocumentSize = 10 << 20
    
    // Reader - JSON record reader for S3Select.
    type Reader struct {
    	args       *ReaderArgs
    	decoder    *jstream.Decoder
    	valueCh    chan *jstream.MetaValue
    	readCloser io.ReadCloser
    }
    
    // Read - reads single record.
    func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    	v, ok := <-r.valueCh
    	if !ok {
    		if err := r.decoder.Err(); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  8. docs/de/docs/tutorial/security/simple-oauth2.md

    Mit diesen Tools können Sie das Sicherheitssystem mit jeder Datenbank und jedem Benutzer oder Datenmodell kompatibel machen.
    
    Das einzige fehlende Detail ist, dass es noch nicht wirklich „sicher“ ist.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  9. cmd/callhome.go

    		internalLogIf(ctx, errors.New("Callhome: object layer not ready"))
    		return
    	}
    
    	healthCtx, healthCancel := context.WithTimeout(ctx, deadline)
    	defer healthCancel()
    
    	healthInfoCh := make(chan madmin.HealthInfo)
    
    	query := url.Values{}
    	for _, k := range madmin.HealthDataTypesList {
    		query.Set(string(k), "true")
    	}
    
    	healthInfo := madmin.HealthInfo{
    		TimeStamp: time.Now().UTC(),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 17 16:53:34 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  10. 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
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Dec 02 16:29:41 UTC 2022
    - 3.3K bytes
    - Viewed (0)
Back to top