wsc

May 1, 2019

Changes in this version

+ var ErrReadMessageDiscarded = fmt.Errorf("read chan full: one or more messages has not been received")

+ var ErrWriteMessageDiscarded = fmt.Errorf("write chan full: one or more messages has not been sent")

+ type Config struct

+ EnableCompression bool

+ Headers http.Header

+ PingPeriod time.Duration

+ PongWait time.Duration

+ ReadBufferSize int

+ ReadChanSize int

+ TLSConfig *tls.Config

+ WriteBufferSize int

+ WriteChanSize int

+ WriteWait time.Duration

+ type MockWebsocket interface

+ LastWrite func() chan []byte

+ NextDone func(err error)

+ NextRead func(data []byte)

+ func NewMockWebsocket(ctx context.Context) MockWebsocket

+ type WSConnection interface

+ Close func() error

+ ReadMessage func() (int, []byte, error)

+ SetCloseHandler func(func(code int, text string) error)

+ SetPongHandler func(func(string) error)

+ SetReadDeadline func(time.Time) error

+ SetWriteDeadline func(time.Time) error

+ WriteControl func(int, []byte, time.Time) error

+ WriteMessage func(int, []byte) error

+ type Websocket interface

+ Close func(code int)

+ Done func() chan error

+ Error func() chan error

+ Read func() chan []byte

+ Write func([]byte)

+ func Accept(ctx context.Context, conn WSConnection, config Config) (Websocket, error)

+ func Connect(ctx context.Context, url string, config Config) (Websocket, *http.Response, error)