stream

Apr 12, 2022

Changes in this version

+ func Tar(writer io.Writer, src string) error

+ func TarBytes(writer io.Writer, bytes []byte) error

+ func Untar(r io.Reader, dst string) error

+ func UntarBytes(dst io.Writer, r io.Reader) error

+ type MessageCloser interface

+ BuildMsg func() interface{}

+ CloseMsg func() interface{}

+ type MessageReadWriteCloser interface

+ BuildMsg func() interface{}

+ CloseMsg func() interface{}

+ GetBytes func(interface{}) ([]byte, error)

+ SetBytes func(interface{}, []byte)

+ type MessageReader interface

+ BuildMsg func() interface{}

+ GetBytes func(interface{}) ([]byte, error)

+ type MessageWriter interface

+ BuildMsg func() interface{}

+ SetBytes func(interface{}, []byte)

+ type ReadWriteCloser struct

+ func NewReadWriteCloser(stream Stream, sm MessageReadWriteCloser) *ReadWriteCloser

+ func (s *ReadWriteCloser) Close() error

+ func (s *ReadWriteCloser) CloseRead() error

+ func (s *ReadWriteCloser) CloseWrite() error

+ func (s *ReadWriteCloser) Read(b []byte) (int, error)

+ func (s *ReadWriteCloser) Write(b []byte) (int, error)

+ type Reader struct

+ func NewReader(stream Stream, sm MessageReader) *Reader

+ func (s *Reader) Read(b []byte) (int, error)

+ type Stream interface

+ RecvMsg func(m interface{}) error

+ SendMsg func(m interface{}) error

+ type Writer struct

+ func NewWriter(stream Stream, sm MessageWriter) *Writer

+ func (s *Writer) Write(b []byte) (int, error)