read fast
parent
f57560ebfc
commit
d73b63f43c
|
|
@ -86,6 +86,6 @@ func Cksum(ctx context.Context, p string) (string, error) {
|
||||||
defer f.Close()
|
defer f.Close()
|
||||||
|
|
||||||
hasher := md5.New()
|
hasher := md5.New()
|
||||||
_, err = io.Copy(hasher, slow.NewReader(ctx, 10_000_000, f))
|
_, err = io.Copy(hasher, slow.NewReader(ctx, 50_000_000, f))
|
||||||
return base64.StdEncoding.EncodeToString(hasher.Sum(nil)), err
|
return base64.StdEncoding.EncodeToString(hasher.Sum(nil)), err
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -18,7 +18,7 @@ var _ io.Reader = Reader{}
|
||||||
func NewReader(ctx context.Context, bps rate.Limit, r io.Reader) Reader {
|
func NewReader(ctx context.Context, bps rate.Limit, r io.Reader) Reader {
|
||||||
return Reader{
|
return Reader{
|
||||||
ctx: ctx,
|
ctx: ctx,
|
||||||
limiter: rate.NewLimiter(bps, 8192),
|
limiter: rate.NewLimiter(bps, int(bps)),
|
||||||
r: r,
|
r: r,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue