stream

Apr 25, 2021

Changes in this version

type Stream

+ func (s *Stream) SetSeekEnd(size int64) error

Feb 22, 2020

Changes in this version

+ var ErrCanceled = errors.New("stream has been canceled")

+ var ErrUnsupported = errors.New("unsupported")

type Reader

+ func (r *Reader) Seek(offset int64, whence int) (int64, error)

type Stream

+ func NewMemStream() *Stream

+ func (s *Stream) Cancel() error

+ func (s *Stream) ShutdownWithErr(err error)

Mar 3, 2017

Changes in this version

type Reader

+ func (r *Reader) Size() (int64, bool)

Jun 4, 2015

Changes in this version

+ var ErrNotFoundInMem = errors.New("not found")

+ var ErrRemoving = errors.New("cannot open a new reader while removing file")

+ type File interface

+ Name func() string

+ type FileSystem interface

+ Create func(name string) (File, error)

+ Open func(name string) (File, error)

+ Remove func(name string) error

+ var StdFileSystem FileSystem = stdFS{}

+ func NewMemFS() FileSystem

+ type Reader struct

+ func (r *Reader) Close() error

+ func (r *Reader) Name() string

+ func (r *Reader) Read(p []byte) (n int, err error)

+ func (r *Reader) ReadAt(p []byte, off int64) (n int, err error)

+ type Stream struct

+ func New(name string) (*Stream, error)

+ func NewStream(name string, fs FileSystem) (*Stream, error)

+ func (s *Stream) Close() error

+ func (s *Stream) Name() string

+ func (s *Stream) NextReader() (*Reader, error)

+ func (s *Stream) Remove() error

+ func (s *Stream) Write(p []byte) (int, error)