syncbuf

Documentation

Index

• type Syncbuf
  • func New() *Syncbuf
  • func (s *Syncbuf) Bytes() []byte
  • func (s *Syncbuf) Read(b []byte) (n int, err error)
  • func (s *Syncbuf) Write(p []byte) (n int, err error)

Types

type Syncbuf

type Syncbuf struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Syncbuf implements a go-routine safe unbounded buffer

func New

func New() *Syncbuf

func (*Syncbuf) Bytes

func (s *Syncbuf) Bytes() []byte

Bytes() returns the current contents of the Syncbuf, without modifying it.

func (*Syncbuf) Read

func (s *Syncbuf) Read(b []byte) (n int, err error)

func (*Syncbuf) Write

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