diff --git a/pkgs/io/ratelimit/readwrite.go b/pkgs/io/ratelimit/readwrite.go index 434f1ba..6bc1b3d 100644 --- a/pkgs/io/ratelimit/readwrite.go +++ b/pkgs/io/ratelimit/readwrite.go @@ -16,6 +16,13 @@ func NewRateLimitReaderWriterCloser(underlay io.ReadWriteCloser, size uint64) io } } +func NewRateLimitReaderWriterCloserShared(underlay io.ReadWriteCloser, l *Limiter) io.ReadWriteCloser { + return &RateLimitReadWriteCloser{ + limiter: l, + underlay: underlay, + } +} + func (r *RateLimitReadWriteCloser) Close() error { return r.underlay.Close() }