Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 84 for ReadAll (0.06 sec)

  1. cmd/dummy-data-generator_test.go

    }
    
    func TestDummyDataGenerator(t *testing.T) {
    	readAll := func(r io.Reader) string {
    		b, _ := io.ReadAll(r)
    		return string(b)
    	}
    	checkEq := func(a, b string) {
    		if a != b {
    			t.Fatalf("Unexpected equality failure")
    		}
    	}
    
    	checkEq(readAll(NewDummyDataGen(0, 0)), "")
    
    	checkEq(readAll(NewDummyDataGen(10, 0)), readAll(NewDummyDataGen(10, int64(len(alphabets)))))
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  2. istioctl/pkg/writer/envoy/configdump/secret_test.go

    			defer configDumpFile.Close()
    			configDump, err := io.ReadAll(configDumpFile)
    			if err != nil {
    				t.Errorf("error reading test data file: %v", err)
    			}
    
    			outFile, err := os.Open(fmt.Sprintf("testdata/secret/%s/output", tc.sds))
    			if err != nil {
    				t.Errorf("error opening test data output file: %v", err)
    			}
    			defer outFile.Close()
    			expectedOut, err := io.ReadAll(outFile)
    			if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 28 19:52:53 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  3. src/archive/zip/writer_test.go

    		if err != nil {
    			t.Errorf("%s: Open err = %v", got.Name, err)
    			continue
    		}
    
    		buf, err := io.ReadAll(r)
    		if err != nil {
    			t.Errorf("%s: ReadAll err = %v", got.Name, err)
    			continue
    		}
    
    		if !bytes.Equal(buf, want.content) {
    			t.Errorf("%v: ReadAll returned unexpected bytes", got.Name)
    		}
    	}
    }
    
    func testCreate(t *testing.T, w *Writer, wt *WriteTest) {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  4. internal/config/crypto.go

    // ciphertext.
    func EncryptBytes(k *kms.KMS, plaintext []byte, context kms.Context) ([]byte, error) {
    	ciphertext, err := Encrypt(k, bytes.NewReader(plaintext), context)
    	if err != nil {
    		return nil, err
    	}
    	return io.ReadAll(ciphertext)
    }
    
    // DecryptBytes decrypts the ciphertext using a key managed by the KMS.
    // The same context that have been used during encryption must be
    // provided.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 5K bytes
    - Viewed (0)
  5. internal/config/crypto_test.go

    			t.Fatalf("Test %d: failed to encrypt stream: %v", i, err)
    		}
    		data, err := io.ReadAll(ciphertext)
    		if err != nil {
    			t.Fatalf("Test %d: failed to encrypt stream: %v", i, err)
    		}
    
    		plaintext, err := Decrypt(KMS, bytes.NewReader(data), test.Context)
    		if err != nil {
    			t.Fatalf("Test %d: failed to decrypt stream: %v", i, err)
    		}
    		data, err = io.ReadAll(plaintext)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  6. internal/ioutil/read_file.go

    	f, err := OsOpenFile(name, readMode, 0o666)
    	if err != nil {
    		return nil, err
    	}
    	defer f.Close()
    	st, err := f.Stat()
    	if err != nil {
    		return io.ReadAll(f)
    	}
    	dst := make([]byte, st.Size())
    	_, err = io.ReadFull(f, dst)
    	return dst, err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 09 18:17:51 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  7. src/bytes/reader_test.go

    	r.Reset([]byte(want))
    	if err := r.UnreadRune(); err == nil {
    		t.Errorf("UnreadRune: expected error, got nil")
    	}
    	buf, err := io.ReadAll(r)
    	if err != nil {
    		t.Errorf("ReadAll: unexpected error: %v", err)
    	}
    	if got := string(buf); got != want {
    		t.Errorf("ReadAll: got %q, want %q", got, want)
    	}
    }
    
    func TestReaderZero(t *testing.T) {
    	if l := (&Reader{}).Len(); l != 0 {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Dec 13 18:45:54 UTC 2021
    - 8K bytes
    - Viewed (0)
  8. cmd/naughty-disk_test.go

    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.WriteAll(ctx, volume, path, b)
    }
    
    func (d *naughtyDisk) ReadAll(ctx context.Context, volume string, path string) (buf []byte, err error) {
    	if err := d.calcError(); err != nil {
    		return nil, err
    	}
    	return d.disk.ReadAll(ctx, volume, path)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  9. docs/iam/access-manager-plugin.go

    		"error": fmt.Sprintf("%v", err),
    	})
    }
    
    type Result struct {
    	Result bool `json:"result"`
    }
    
    func mainHandler(w http.ResponseWriter, r *http.Request) {
    	body, err := io.ReadAll(r.Body)
    	if err != nil {
    		writeErrorResponse(w, err)
    		return
    	}
    
    	var out bytes.Buffer
    	json.Indent(&out, body, "", "  ")
    	fmt.Printf("Received JSON payload:\n%s\n", out.String())
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 08 17:15:20 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  10. samples/guide/src/main/java/okhttp3/recipes/kt/PostPath.kt

            .build()
    
        client.newCall(request).execute().use { response ->
          if (!response.isSuccessful) throw IOException("Unexpected code $response")
    
          fileSystem.sink(path).use {
            response.body.source().readAll(it)
          }
    
          println(fileSystem.source(path).buffer().readUtf8())
        }
      }
    
      companion object {
        val MEDIA_TYPE_JSON = "application/json".toMediaType()
      }
    }
    
    fun main() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.6K bytes
    - Viewed (0)
Back to top