Versions in this module Expand all Collapse all v0 v0.1.4 Mar 31, 2021 Changes in this version + var ErrCorrupt = errors.New("recio: corrupt") + var ErrMustFill = errors.New("recio: must fill") + var ErrMustFlush = errors.New("recio: must flush") + var ErrShortBuffer = errors.New("recio: short buffer") + var ErrShortWrite = errors.New("recio: short write") + var ErrTooLarge = errors.New("recio: too large") + type AtomicReader struct + func NewAtomicReader(r Reader) (ar *AtomicReader) + func (ar *AtomicReader) Read(v Decoder) (n int, err error) + type AtomicWriter struct + func NewAtomicWriter(w Writer) (aw *AtomicWriter) + func (aw *AtomicWriter) Write(v Encoder) (n int, err error) + type BufferedReader struct + func NewBufferedReader(r io.Reader, size int, mode IOMode) (br *BufferedReader) + func (br *BufferedReader) Fill() (err error) + func (br *BufferedReader) Read(v Decoder) (n int, err error) + func (br *BufferedReader) Reset(r io.Reader) + type BufferedWriter struct + func NewBufferedWriter(w io.Writer, size int, mode IOMode) (bw *BufferedWriter) + func (bw *BufferedWriter) Flush() (err error) + func (bw *BufferedWriter) Reset(w io.Writer) + func (bw *BufferedWriter) Write(v Encoder) (n int, err error) + type Decoder interface + Decode func(p []byte) (n int, err error) + type EncodeDecoder interface + Decode func(p []byte) (n int, err error) + Encode func(p []byte) (n int, err error) + type Encoder interface + Encode func(p []byte) (n int, err error) + type IOMode int + const ModeAuto + const ModeManual + type Reader interface + Read func(v Decoder) (n int, err error) + type Writer interface + Write func(v Encoder) (n int, err error)