parser

Apr 11, 2018

Changes in this version

+ const Protocol

+ type PacketDecoder struct

+ func NewDecoder(r io.Reader) (*PacketDecoder, error)

+ func (d *PacketDecoder) Close() error

+ func (d *PacketDecoder) MessageType() message.MessageType

+ func (d *PacketDecoder) Read(p []byte) (int, error)

+ func (d *PacketDecoder) Type() PacketType

+ type PacketEncoder struct

+ func NewB64Encoder(w io.Writer, t PacketType) (*PacketEncoder, error)

+ func NewBinaryEncoder(w io.Writer, t PacketType) (*PacketEncoder, error)

+ func NewStringEncoder(w io.Writer, t PacketType) (*PacketEncoder, error)

+ func (e *PacketEncoder) Close() error

+ func (e *PacketEncoder) Write(p []byte) (int, error)

+ type PacketType string

+ const CLOSE

+ const MESSAGE

+ const NOOP

+ const OPEN

+ const PING

+ const PONG

+ const UPGRADE

+ func ByteToType(b byte) (PacketType, error)

+ func (t PacketType) Byte() byte

+ type PayloadDecoder struct

+ func NewPayloadDecoder(r io.Reader) *PayloadDecoder

+ func (d *PayloadDecoder) Next() (*PacketDecoder, error)

+ type PayloadEncoder struct

+ func NewBinaryPayloadEncoder() *PayloadEncoder

+ func NewStringPayloadEncoder() *PayloadEncoder

+ func (e *PayloadEncoder) EncodeTo(w io.Writer) error

+ func (e *PayloadEncoder) IsString() bool

+ func (e *PayloadEncoder) NextBinary(t PacketType) (io.WriteCloser, error)

+ func (e *PayloadEncoder) NextString(t PacketType) (io.WriteCloser, error)