io

Apr 19, 2016

Changes in this version

+ func Pipe(reader Reader, writer Writer) error

type AdaptiveReader

+ func (this *AdaptiveReader) Release()

type AdaptiveWriter

+ func (this *AdaptiveWriter) Release()

Feb 28, 2016

Changes in this version

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

+ func NewAdaptiveReader(reader io.Reader) *AdaptiveReader

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

+ type AdaptiveWriter struct

+ func NewAdaptiveWriter(writer io.Writer) *AdaptiveWriter

+ 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

Sep 28, 2015

Changes in this version

+ type CryptionReader struct

+ func NewAesDecryptReader(key []byte, iv []byte, reader io.Reader) (*CryptionReader, error)

+ func NewCryptionReader(stream cipher.Stream, reader io.Reader) *CryptionReader

+ func (reader CryptionReader) Read(blocks []byte) (int, error)

+ type CryptionWriter struct

+ func NewAesEncryptWriter(key []byte, iv []byte, writer io.Writer) (*CryptionWriter, error)

+ func NewCryptionWriter(stream cipher.Stream, writer io.Writer) *CryptionWriter

+ func (writer CryptionWriter) Crypt(blocks []byte)

+ func (writer CryptionWriter) Write(blocks []byte) (int, error)