Versions in this module Expand all Collapse all v1 v1.0.1 Feb 17, 2019 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)