io

Documentation

Index

• func ChanToRawWriter(writer io.Writer, stream <-chan *alloc.Buffer) error
• func ChanToWriter(writer Writer, stream <-chan *alloc.Buffer) error
• func RawReaderToChan(stream chan<- *alloc.Buffer, reader io.Reader) error
• func ReadFrom(reader io.Reader, buffer *alloc.Buffer) (*alloc.Buffer, error)
• func ReaderToChan(stream chan<- *alloc.Buffer, reader Reader) error
• type AdaptiveReader
  • func NewAdaptiveReader(reader io.Reader) *AdaptiveReader
  • func (this *AdaptiveReader) Read() (*alloc.Buffer, error)
• type AdaptiveWriter
  • func NewAdaptiveWriter(writer io.Writer) *AdaptiveWriter
  • 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) Release()
  • func (this *BufferedWriter) SetCached(cached bool)
  • func (this *BufferedWriter) Write(b []byte) (int, error)
• type Reader
• type Writer

Functions

func ChanToRawWriter

func ChanToRawWriter(writer io.Writer, stream <-chan *alloc.Buffer) error

func ChanToWriter

func ChanToWriter(writer Writer, stream <-chan *alloc.Buffer) error

ChanToWriter dumps all content from a given chan to a writer until the chan is closed.

func RawReaderToChan

func RawReaderToChan(stream chan<- *alloc.Buffer, reader io.Reader) error

func ReadFrom

func ReadFrom(reader io.Reader, buffer *alloc.Buffer) (*alloc.Buffer, error)

ReadFrom reads from a reader and put all content to a buffer. If buffer is nil, ReadFrom creates a new normal buffer.

func ReaderToChan

func ReaderToChan(stream chan<- *alloc.Buffer, reader Reader) error

ReaderToChan dumps all content from a given reader to a chan by constantly reading it until EOF.

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.

func (*AdaptiveReader) Read

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

Read implements Reader.Read().

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) Write

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

Write implements Writer.Write().

type BufferedReader

type BufferedReader struct {
	// 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 {
	// 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) 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 Reader

type Reader interface {
	// 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 {
	// Write writes an alloc.Buffer into underlying writer.
	Write(*alloc.Buffer) error
}

Writer extends io.Writer with alloc.Buffer.