Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 476 for readLen (0.06 sec)

  1. mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt

          }
    
        public fun shutdownServer(shutdownServer: Boolean): Builder =
          apply {
            this.shutdownServer = shutdownServer
          }
    
        /**
         * Throttles the request reader and response writer to sleep for the given period after each
         * series of [bytesPerPeriod] bytes are transferred. Use this to simulate network behavior.
         */
        public fun throttleBody(
          bytesPerPeriod: Long,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 17.8K bytes
    - Viewed (0)
  2. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 28.1K bytes
    - Viewed (0)
  3. src/bytes/buffer_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	if i != 0 {
    		t.Fatalf("unexpected return from bytes.ReadFrom (1): got: %d, want %d", i, 0)
    	}
    	check(t, "TestReadFromPanicReader (1)", &buf, "")
    
    	// Confirm that when Reader panics, the empty buffer remains empty
    	var buf2 Buffer
    	defer func() {
    		recover()
    		check(t, "TestReadFromPanicReader (2)", &buf2, "")
    	}()
    	buf2.ReadFrom(panicReader{panic: true})
    }
    
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon May 19 16:13:04 UTC 2025
    - 18.6K bytes
    - Viewed (0)
  4. 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 Sep 09 11:13:09 UTC 2025
    - Last Modified: Thu Jul 25 00:25:45 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  5. cmd/tier.go

    	}
    
    	// Note: Local variables with names ek, oek, etc are named inline with
    	// acronyms defined here -
    	// https://github.com/minio/minio/blob/master/docs/security/README.md#acronyms
    
    	// Encrypt json encoded tier configurations
    	metadata := make(map[string]string)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/io/Files.java

     *
     * @author Chris Nokleberg
     * @author Colin Decker
     * @since 1.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    public final class Files {
    
      private Files() {}
    
      /**
       * Returns a buffered reader that reads from a file using the given character set.
       *
       * <p><b>{@link java.nio.file.Path} equivalent:</b> {@link
       * java.nio.file.Files#newBufferedReader(java.nio.file.Path, Charset)}.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 32.9K bytes
    - Viewed (0)
  7. guava/src/com/google/common/io/Files.java

     *
     * @author Chris Nokleberg
     * @author Colin Decker
     * @since 1.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    public final class Files {
    
      private Files() {}
    
      /**
       * Returns a buffered reader that reads from a file using the given character set.
       *
       * <p><b>{@link java.nio.file.Path} equivalent:</b> {@link
       * java.nio.file.Files#newBufferedReader(java.nio.file.Path, Charset)}.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 32.9K bytes
    - Viewed (0)
  8. cmd/handler-utils.go

    	xnet "github.com/minio/pkg/v3/net"
    )
    
    const (
    	copyDirective    = "COPY"
    	replaceDirective = "REPLACE"
    	accessDirective  = "ACCESS"
    )
    
    // Parses location constraint from the incoming reader.
    func parseLocationConstraint(r *http.Request) (location string, s3Error APIErrorCode) {
    	// If the request has no body with content-length set to 0,
    	// we do not have to validate location constraint. Bucket will
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.3K bytes
    - Viewed (1)
  9. docs/bucket/replication/DESIGN.md

    ## Overview
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  10. src/bytes/example_test.go

    	b.Write([]byte("Hello "))
    	fmt.Fprintf(&b, "world!")
    	b.WriteTo(os.Stdout)
    	// Output: Hello world!
    }
    
    func ExampleBuffer_reader() {
    	// A Buffer can turn a string or a []byte into an io.Reader.
    	buf := bytes.NewBufferString("R29waGVycyBydWxlIQ==")
    	dec := base64.NewDecoder(base64.StdEncoding, buf)
    	io.Copy(os.Stdout, dec)
    	// Output: Gophers rule!
    }
    
    func ExampleBuffer_Bytes() {
    	buf := bytes.Buffer{}
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon May 12 16:07:54 UTC 2025
    - 16.5K bytes
    - Viewed (0)
Back to top