io

Documentation

Index

• func Pipe(reader Reader, writer Writer) error
• func PipeUntilEOF(reader Reader, writer Writer) error
• type AdaptiveReader
  • func NewAdaptiveReader(reader io.Reader) *AdaptiveReader
  • func (this *AdaptiveReader) Read() (*alloc.Buffer, error)
  • func (this *AdaptiveReader) Release()
• type AdaptiveWriter
  • func NewAdaptiveWriter(writer io.Writer) *AdaptiveWriter
  • func (this *AdaptiveWriter) Release()
  • func (this *AdaptiveWriter) Write(buffer *alloc.Buffer) error
• type BufferedReader
  • func NewBufferedReader(rawReader io.Reader) *BufferedReader
  • func (this *BufferedReader) Cached() bool
  • func (this *BufferedReader) Read(b []byte) (int, error)
  • func (this *BufferedReader) Release()
  • func (this *BufferedReader) SetCached(cached bool)
• type BufferedWriter
  • func NewBufferedWriter(rawWriter io.Writer) *BufferedWriter
  • func (this *BufferedWriter) Cached() bool
  • func (this *BufferedWriter) Flush() error
  • func (this *BufferedWriter) FlushWithoutLock() error
  • func (this *BufferedWriter) ReadFrom(reader io.Reader) (int64, error)
  • func (this *BufferedWriter) Release()
  • func (this *BufferedWriter) SetCached(cached bool)
  • func (this *BufferedWriter) Write(b []byte) (int, error)
• type ChainWriter
  • func NewChainWriter(writer Writer) *ChainWriter
  • func (this *ChainWriter) Release()
  • func (this *ChainWriter) Write(payload []byte) (int, error)
• type ChanReader
  • func NewChanReader(stream Reader) *ChanReader
  • func (this *ChanReader) Fill()
  • func (this *ChanReader) Read(b []byte) (int, error)
  • func (this *ChanReader) Release()
• type Reader
• type Writer

Functions

func Pipe

func Pipe(reader Reader, writer Writer) error

func PipeUntilEOF

func PipeUntilEOF(reader Reader, writer Writer) error

Types

type AdaptiveReader

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

AdaptiveReader is a Reader that adjusts its reading speed automatically.

func NewAdaptiveReader

func NewAdaptiveReader(reader io.Reader) *AdaptiveReader

NewAdaptiveReader creates a new AdaptiveReader. The AdaptiveReader instance doesn't take the ownership of reader.

func (*AdaptiveReader) Read

func (this *AdaptiveReader) Read() (*alloc.Buffer, error)

Read implements Reader.Read().

func (*AdaptiveReader) Release

func (this *AdaptiveReader) Release()

type AdaptiveWriter

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

AdaptiveWriter is a Writer that writes alloc.Buffer into underlying writer.

func NewAdaptiveWriter

func NewAdaptiveWriter(writer io.Writer) *AdaptiveWriter

NewAdaptiveWriter creates a new AdaptiveWriter.

func (*AdaptiveWriter) Release

func (this *AdaptiveWriter) Release()

func (*AdaptiveWriter) Write

func (this *AdaptiveWriter) Write(buffer *alloc.Buffer) error

Write implements Writer.Write(). Write() takes ownership of the given buffer.

type BufferedReader

type BufferedReader struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewBufferedReader

func NewBufferedReader(rawReader io.Reader) *BufferedReader

func (*BufferedReader) Cached

func (this *BufferedReader) Cached() bool

func (*BufferedReader) Read

func (this *BufferedReader) Read(b []byte) (int, error)

func (*BufferedReader) Release

func (this *BufferedReader) Release()

func (*BufferedReader) SetCached

func (this *BufferedReader) SetCached(cached bool)

type BufferedWriter

type BufferedWriter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewBufferedWriter

func NewBufferedWriter(rawWriter io.Writer) *BufferedWriter

func (*BufferedWriter) Cached

func (this *BufferedWriter) Cached() bool

func (*BufferedWriter) Flush

func (this *BufferedWriter) Flush() error

func (*BufferedWriter) FlushWithoutLock

func (this *BufferedWriter) FlushWithoutLock() error

func (*BufferedWriter) ReadFrom

func (this *BufferedWriter) ReadFrom(reader io.Reader) (int64, error)

func (*BufferedWriter) Release

func (this *BufferedWriter) Release()

func (*BufferedWriter) SetCached

func (this *BufferedWriter) SetCached(cached bool)

func (*BufferedWriter) Write

func (this *BufferedWriter) Write(b []byte) (int, error)

type ChainWriter

type ChainWriter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewChainWriter

func NewChainWriter(writer Writer) *ChainWriter

func (*ChainWriter) Release

func (this *ChainWriter) Release()

func (*ChainWriter) Write

func (this *ChainWriter) Write(payload []byte) (int, error)

type ChanReader

type ChanReader struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewChanReader

func NewChanReader(stream Reader) *ChanReader

func (*ChanReader) Fill

func (this *ChanReader) Fill()

Private: Visible for testing.

func (*ChanReader) Read

func (this *ChanReader) Read(b []byte) (int, error)

func (*ChanReader) Release

func (this *ChanReader) Release()

type Reader

type Reader interface {
	common.Releasable
	// Read reads content from underlying reader, and put it into an alloc.Buffer.
	Read() (*alloc.Buffer, error)
}

Reader extends io.Reader with alloc.Buffer.

type Writer

type Writer interface {
	common.Releasable
	// Write writes an alloc.Buffer into underlying writer.
	Write(*alloc.Buffer) error
}

Writer extends io.Writer with alloc.Buffer.