io

Documentation

Index

• func ReadTlvStream(reader io.Reader, onFrame func([]byte) bool, ignoreError func(error) bool) error
• type TimedWriter
  • func NewTimedWriter(io io.Writer, bufsize int) *TimedWriter
  • func (w *TimedWriter) Flush() error
  • func (w *TimedWriter) SetDeadline(d time.Duration)
  • func (w *TimedWriter) SetMaxQueue(s int)
  • func (w *TimedWriter) Write(p []byte) (n int, err error)

Functions

func ReadTlvStream

func ReadTlvStream(
	reader io.Reader,
	onFrame func([]byte) bool,
	ignoreError func(error) bool,
) error

Types

type TimedWriter

type TimedWriter struct {
	*bufio.Writer
	// contains filtered or unexported fields
}

TimedWriter is a buffered writer that flushes automatically when a deadline is set and the deadline is exceeded.

func NewTimedWriter

func NewTimedWriter(io io.Writer, bufsize int) *TimedWriter

func (*TimedWriter) Flush

func (w *TimedWriter) Flush() error

func (*TimedWriter) SetDeadline

func (w *TimedWriter) SetDeadline(d time.Duration)

func (*TimedWriter) SetMaxQueue

func (w *TimedWriter) SetMaxQueue(s int)

func (*TimedWriter) Write

func (w *TimedWriter) Write(p []byte) (n int, err error)