util

Documentation

Index

• type SmoothStream
  • func NewSmoothStream() *SmoothStream
  • func (stream *SmoothStream) Close()
  • func (stream *SmoothStream) DoneWrite()
  • func (stream *SmoothStream) Recv() (rune, error)
  • func (stream *SmoothStream) Write(r rune)
  • func (stream *SmoothStream) WriteError(err error)

Types

type SmoothStream

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

SmoothStream a stream that regulates the reading speed of readers.

func NewSmoothStream

func NewSmoothStream() *SmoothStream

func (*SmoothStream) Close

func (stream *SmoothStream) Close()

func (*SmoothStream) DoneWrite

func (stream *SmoothStream) DoneWrite()

func (*SmoothStream) Recv

func (stream *SmoothStream) Recv() (rune, error)

Recv is not safe for concurrent read. Recv returns io.EOF or other errors Its callers' responsibility to close SmoothStream

func (*SmoothStream) Write

func (stream *SmoothStream) Write(r rune)

func (*SmoothStream) WriteError

func (stream *SmoothStream) WriteError(err error)

WriteError io.EOF or other errors