writeconcurrencylimiter

Documentation

Index

• func PutReader(r *Reader)
• type Reader
  • func GetReader(r io.Reader) *Reader
  • func (r *Reader) DecConcurrency()
  • func (r *Reader) Read(p []byte) (int, error)

Functions

func PutReader

func PutReader(r *Reader)

PutReader returns the r to the pool.

It decreases the concurrency if r has increased concurrency.

Types

type Reader

type Reader struct {
	// contains filtered or unexported fields
}

Reader is a reader, which increases the concurrency after the first Read() call

The concurrency can be reduced by calling DecConcurrency(). Then the concurrency is increased after the next Read() call.

func GetReader

func GetReader(r io.Reader) *Reader

GetReader returns the Reader for r.

The PutReader() must be called when the returned Reader is no longer needed.

func (*Reader) DecConcurrency

func (r *Reader) DecConcurrency()

DecConcurrency decreases the concurrency, so it could be increased again after the next Read() call.

func (*Reader) Read

func (r *Reader) Read(p []byte) (int, error)

Read implements io.Reader.

It increases concurrency after the first call or after the next call after DecConcurrency() call.