Search Options

Results per page
Sort
Preferred Languages
Advance

Results 561 - 570 of 769 for readTo (0.23 sec)

  1. cmd/test-utils_test.go

    	var priv interface{}
    	var err error
    	priv, err = rsa.GenerateKey(crand.Reader, rsaBits)
    	if err != nil {
    		return nil, nil, fmt.Errorf("failed to generate private key: %w", err)
    	}
    
    	notBefore := time.Now()
    	notAfter := notBefore.Add(validFor)
    
    	serialNumberLimit := new(big.Int).Lsh(big.NewInt(1), 128)
    	serialNumber, err := crand.Int(crand.Reader, serialNumberLimit)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  2. src/bytes/buffer_test.go

    	// check not at EOF
    	b.WriteString("abcdefghijklmnopqrstuvwxyz")
    
    	// after unsuccessful read
    	if n, err := b.Read(nil); n != 0 || err != nil {
    		t.Fatalf("Read(nil) = %d,%v; want 0,nil", n, err)
    	}
    	if err := b.UnreadByte(); err == nil {
    		t.Fatal("UnreadByte after Read(nil): got no error")
    	}
    
    	// after successful read
    	if _, err := b.ReadBytes('m'); err != nil {
    		t.Fatalf("ReadBytes: %v", err)
    	}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Sep 03 20:55:15 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  3. src/archive/tar/tar_test.go

    					}
    					if err := tw.Close(); err != nil {
    						b.Errorf("unexpected Close error: %v", err)
    					}
    				}
    			})
    		}
    	})
    
    	b.Run("Reader", func(b *testing.B) {
    		for _, v := range vectors {
    			var buf bytes.Buffer
    			var r bytes.Reader
    
    			// Write the archive to a byte buffer.
    			tw := NewWriter(&buf)
    			for _, file := range v.files {
    				tw.WriteHeader(file.hdr)
    				tw.Write(file.body)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jul 25 00:25:45 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  4. android/guava-testlib/src/com/google/common/testing/FreshValueGenerator.java

    import com.google.common.reflect.Reflection;
    import com.google.common.reflect.TypeToken;
    import java.io.ByteArrayInputStream;
    import java.io.File;
    import java.io.InputStream;
    import java.io.Reader;
    import java.io.StringReader;
    import java.lang.annotation.ElementType;
    import java.lang.annotation.Retention;
    import java.lang.annotation.RetentionPolicy;
    import java.lang.annotation.Target;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  5. cmd/erasure-multipart.go

    	if !opts.NoAuditLog {
    		auditObjectErasureSet(ctx, "PutObjectPart", object, &er)
    	}
    
    	data := r.Reader
    	// Validate input data size and it can never be less than zero.
    	if data.Size() < -1 {
    		bugLogIf(ctx, errInvalidArgument, logger.ErrorKind)
    		return pi, toObjectErr(errInvalidArgument)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  6. cmd/xl-storage_test.go

    	w := newStreamingBitrotWriter(storage, "", volName, fileName, size, algo, shardSize)
    	reader := bytes.NewReader(data)
    	for {
    		// Using io.Copy instead of this loop will not work for us as io.Copy
    		// will use bytes.Reader.WriteTo() which will not do shardSize'ed writes
    		// causing error.
    		n, err := reader.Read(shard)
    		w.Write(shard[:n])
    		if err == nil {
    			continue
    		}
    		if err == io.EOF {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  7. docs/pl/docs/features.md

    Cała struktura frameworku **FastAPI** jest na tym oparta. Autouzupełnianie działa wszędzie.
    
    Rzadko będziesz musiał wracać do dokumentacji.
    
    Oto, jak twój edytor może Ci pomóc:
    
    * <a href="https://code.visualstudio.com/" class="external-link" target="_blank">Visual Studio Code</a>:
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  8. internal/logger/target/kafka/kafka.go

    type Target struct {
    	status int32
    
    	totalMessages  int64
    	failedMessages int64
    
    	wg sync.WaitGroup
    
    	// Channel of log entries.
    	// Reading logCh must hold read lock on logChMu (to avoid read race)
    	// Sending a value on logCh must hold read lock on logChMu (to avoid closing)
    	logCh   chan interface{}
    	logChMu sync.RWMutex
    
    	// store to persist and replay the logs to the target
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  9. cmd/bucket-replication.go

    	}
    	closeReader := func() { obj.Close() }
    	reader, err := fn(obj, h, closeReader)
    	if err != nil {
    		return nil, proxy, err
    	}
    	reader.ObjInfo = oi.Clone()
    	if rs != nil {
    		contentSize, err := parseSizeFromContentRange(h)
    		if err != nil {
    			return nil, proxy, err
    		}
    		reader.ObjInfo.Size = contentSize
    	}
    
    	return reader, proxyResult{Proxy: true}, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  10. docs/es/docs/features.md

    El framework **FastAPI** está creado para satisfacer eso. El auto-completado funciona en todas partes.
    
    No vas a tener que volver a la documentación seguido.
    
    Así es como tu editor te puede ayudar:
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Aug 19 18:15:21 UTC 2024
    - 10.9K bytes
    - Viewed (0)
Back to top