ioutil

Documentation

Index

• func TimeoutReader(ctx context.Context, r io.Reader, timeout time.Duration, cancel func(uint64)) io.Reader
• type WriterFunc
  • func (f WriterFunc) Write(p []byte) (n int, err error)

Functions

func TimeoutReader

func TimeoutReader(ctx context.Context, r io.Reader, timeout time.Duration, cancel func(uint64)) io.Reader

TimeoutReader creates a new timeoutReader instance and starts a goroutine that monitors the progress of reading from the given reader. If no progress is made for the duration of the given timeout, then the reader executes the given cancel function and terminates the underlying goroutine. This goroutine will also terminate when the given context is canceled or if an error is returned by the given reader.

Types

type WriterFunc

type WriterFunc func([]byte) (int, error)

The WriterFunc type is an adapter to allow the use of ordinary functions as io.Writer Write method. If f is a function with the appropriate signature, WriterFunc(f) is an io.Writer that calls f.

func (WriterFunc) Write

func (f WriterFunc) Write(p []byte) (n int, err error)

WriterFunc calls f(p).