Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for pipe (0.17 sec)

  1. cmd/storage-rest-client.go

    	}
    	respBody, err := client.call(ctx, storageRESTMethodReadMultiple, nil, bytes.NewReader(body), int64(len(body)))
    	if err != nil {
    		return err
    	}
    	defer xhttp.DrainBody(respBody)
    
    	pr, pw := io.Pipe()
    	go func() {
    		pw.CloseWithError(waitForHTTPStream(respBody, pw))
    	}()
    	mr := msgp.NewReader(pr)
    	defer readMsgpReaderPoolPut(mr)
    	for {
    		var file ReadMultipleResp
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
Back to top