connection

Documentation

Index

• type Connection
  • func NewConnection(wsConn *websocket.Conn, log logger.Logger) *Connection
  • func (c *Connection) Close() error
  • func (c *Connection) Read() (int, []byte, error)
  • func (c *Connection) Write(data []byte) error

Types

type Connection

type Connection struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Connection represents wrapped and safe to use from the different threads websocket connection

func NewConnection

func NewConnection(wsConn *websocket.Conn, log logger.Logger) *Connection

func (*Connection) Close

func (c *Connection) Close() error

func (*Connection) Read

func (c *Connection) Read() (int, []byte, error)

func (*Connection) Write

func (c *Connection) Write(data []byte) error