io

Jul 4, 2016

Changes in this version

type BufferedWriter

+ func (this *BufferedWriter) FlushWithoutLock() error

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

+ type ChainWriter struct

+ func NewChainWriter(writer Writer) *ChainWriter

+ func (this *ChainWriter) Release()

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

+ type ChanReader struct

+ func NewChanReader(stream Reader) *ChanReader

+ func (this *ChanReader) Fill()

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

+ func (this *ChanReader) Release()

May 22, 2016

Changes in this version

+ func Pipe(reader Reader, writer Writer) error

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

+ type AdaptiveReader struct

+ func NewAdaptiveReader(reader io.Reader) *AdaptiveReader

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

+ func (this *AdaptiveReader) Release()

+ type AdaptiveWriter struct

+ func NewAdaptiveWriter(writer io.Writer) *AdaptiveWriter

+ func (this *AdaptiveWriter) Release()

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

+ type BufferedReader struct

+ 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 struct

+ 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 interface

+ Read func() (*alloc.Buffer, error)

+ type Writer interface

+ Write func(*alloc.Buffer) error