iotool

Documentation

Index

• Variables
• type SafeWriter
  • func (s *SafeWriter) SetWriter(w io.Writer)
  • func (s *SafeWriter) Write(p []byte) (int, error)
• type TimeoutWriter
  • func NewTimeoutWriter(w io.Writer, patience time.Duration) *TimeoutWriter
  • func NewTimeoutWriterFromChan(w io.Writer, done <-chan time.Time) *TimeoutWriter
  • func (w *TimeoutWriter) Finished()
  • func (w *TimeoutWriter) Write(p []byte) (int, error)

Variables

var TimeoutErr = fmt.Errorf("writer closed due to timeout")

Types

type SafeWriter

type SafeWriter struct {
	W io.Writer
	// contains filtered or unexported fields
}

SafeWriter provides a thread-safe io.Writer

func (*SafeWriter) SetWriter

func (s *SafeWriter) SetWriter(w io.Writer)

func (*SafeWriter) Write

func (s *SafeWriter) Write(p []byte) (int, error)

type TimeoutWriter

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

TimeoutWriter accepts input until expiration, then returns errors.

An error will be written to the wrapped writer unless `Finished` is called before the timeout.

func NewTimeoutWriter

func NewTimeoutWriter(w io.Writer, patience time.Duration) *TimeoutWriter

func NewTimeoutWriterFromChan

func NewTimeoutWriterFromChan(w io.Writer, done <-chan time.Time) *TimeoutWriter

func (*TimeoutWriter) Finished

func (w *TimeoutWriter) Finished()

func (*TimeoutWriter) Write

func (w *TimeoutWriter) Write(p []byte) (int, error)