stream

Documentation

Index

• type ReadWriteStream
  • func NewReadWriteStream() *ReadWriteStream
  • func (s *ReadWriteStream) Close() error
  • func (s *ReadWriteStream) IsEndOfStream() bool
  • func (s *ReadWriteStream) Read(p []byte) (n int, err error)
  • func (s *ReadWriteStream) ReadPosition() int64
  • func (s *ReadWriteStream) SetEndOfStream(value bool)
  • func (s *ReadWriteStream) Write(p []byte) (n int, err error)
  • func (s *ReadWriteStream) WritePosition() int64

Types

type ReadWriteStream

type ReadWriteStream struct {
	// contains filtered or unexported fields
}

ReadWriteStream is a thread-safe in-memory stream that can be read from and written to concurrently

func NewReadWriteStream

func NewReadWriteStream() *ReadWriteStream

NewReadWriteStream creates a new ReadWriteStream

func (*ReadWriteStream) Close

func (s *ReadWriteStream) Close() error

Close marks the stream as ended

func (*ReadWriteStream) IsEndOfStream

func (s *ReadWriteStream) IsEndOfStream() bool

IsEndOfStream returns whether the stream has been closed

func (*ReadWriteStream) Read

func (s *ReadWriteStream) Read(p []byte) (n int, err error)

Read implements io.Reader

func (*ReadWriteStream) ReadPosition

func (s *ReadWriteStream) ReadPosition() int64

ReadPosition returns the current read position

func (*ReadWriteStream) SetEndOfStream

func (s *ReadWriteStream) SetEndOfStream(value bool)

SetEndOfStream marks the stream as ended

func (*ReadWriteStream) Write

func (s *ReadWriteStream) Write(p []byte) (n int, err error)

Write implements io.Writer

func (*ReadWriteStream) WritePosition

func (s *ReadWriteStream) WritePosition() int64

WritePosition returns the current write position