wsutil

Dec 9, 2020

Changes in this version

+ var DefaultWriteBuffer = 4096

+ var ErrControlOverflow = fmt.Errorf("control frame payload overflow")

+ var ErrNoFrameAdvance = errors.New("no frame advance")

+ var ErrNotEmpty = fmt.Errorf("writer not empty")

+ func PutWriter(w *Writer)

+ func WriteMessage(w io.Writer, s ws.State, op ws.OpCode, p []byte) error

+ type CipherReader struct

+ func NewCipherReader(r io.Reader, mask [4]byte) *CipherReader

+ func (c *CipherReader) Read(p []byte) (n int, err error)

+ func (c *CipherReader) Reset(r io.Reader, mask [4]byte)

+ type CipherWriter struct

+ func NewCipherWriter(w io.Writer, mask [4]byte) *CipherWriter

+ func (c *CipherWriter) Reset(w io.Writer, mask [4]byte)

+ func (c *CipherWriter) Write(p []byte) (n int, err error)

+ type ControlWriter struct

+ func NewControlWriter(dest io.Writer, state ws.State, op ws.OpCode) *ControlWriter

+ func NewControlWriterBuffer(dest io.Writer, state ws.State, op ws.OpCode, buf []byte) *ControlWriter

+ func (c *ControlWriter) Flush() error

+ func (c *ControlWriter) Write(p []byte) (n int, err error)

+ type FrameHandlerFunc func(ws.Header, io.Reader) error

+ type Message struct

+ OpCode ws.OpCode

+ Payload []byte

+ func ReadMessage(r io.Reader, s ws.State, m []Message) ([]Message, error)

+ type Reader struct

+ OnContinuation FrameHandlerFunc

+ OnIntermediate FrameHandlerFunc

+ SkipHeaderCheck bool

+ Source io.Reader

+ State ws.State

+ func NewReader(r io.Reader, s ws.State) *Reader

+ func (r *Reader) Discard() (err error)

+ func (r *Reader) NextFrame() (hdr ws.Header, err error)

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

+ type Writer struct

+ func GetWriter(dest io.Writer, state ws.State, op ws.OpCode, n int) *Writer

+ func NewWriter(dest io.Writer, state ws.State, op ws.OpCode) *Writer

+ func NewWriterBuffer(dest io.Writer, state ws.State, op ws.OpCode, buf []byte) *Writer

+ func NewWriterBufferSize(dest io.Writer, state ws.State, op ws.OpCode, n int) *Writer

+ func NewWriterSize(dest io.Writer, state ws.State, op ws.OpCode, n int) *Writer

+ func (w *Writer) Available() int

+ func (w *Writer) Buffered() int

+ func (w *Writer) Flush() error

+ func (w *Writer) FlushFragment() error

+ func (w *Writer) ReadFrom(src io.Reader) (n int64, err error)

+ func (w *Writer) Reset(dest io.Writer, state ws.State, op ws.OpCode)

+ func (w *Writer) Size() int

+ func (w *Writer) Write(p []byte) (n int, err error)

+ func (w *Writer) WriteThrough(p []byte) (n int, err error)