socket

Documentation

Index

• func ArgAt[T any](args []any, idx int) (T, error)
• func GetAckFunc(args []any) (func(...any), bool)
• func IO(conn *websocket.Conn, initFn func(s *Socket) error) error
• type Adapter
• type Args
• type Packet
• type Socket
  • func New(adapter Adapter) (*Socket, error)
  • func (s *Socket) Client() *room.Client[Args]
  • func (s *Socket) Connected() bool
  • func (s *Socket) Disconnected() bool
  • func (s *Socket) Emit(event string, args ...any) error
  • func (s *Socket) ID() string
  • func (s *Socket) Off(event string, fn func(args ...any)) *Socket
  • func (s *Socket) On(event string, fn func(args ...any)) *Socket
• type WebSocketAdapter
  • func NewWebSocketAdapter(conn *websocket.Conn) *WebSocketAdapter
  • func (w *WebSocketAdapter) Close() error
  • func (w *WebSocketAdapter) Receive() (Packet, error)
  • func (w *WebSocketAdapter) Send(pkt Packet) error

Functions

func ArgAt

func ArgAt[T any](args []any, idx int) (T, error)

func GetAckFunc

func GetAckFunc(args []any) (func(...any), bool)

func IO

func IO(conn *websocket.Conn, initFn func(s *Socket) error) error

Types

type Adapter

type Adapter interface {
	Receive() (Packet, error)
	Send(Packet) error
	Close() error
}

type Args

type Args []any

type Packet

type Packet struct {
	Type string         `json:"type"`
	Data map[string]any `json:"data"`
}

type Socket

type Socket struct {
	// contains filtered or unexported fields
}

func New

func New(adapter Adapter) (*Socket, error)

func (*Socket) Client

func (s *Socket) Client() *room.Client[Args]

func (*Socket) Connected

func (s *Socket) Connected() bool

func (*Socket) Disconnected

func (s *Socket) Disconnected() bool

func (*Socket) Emit

func (s *Socket) Emit(event string, args ...any) error

func (*Socket) ID

func (s *Socket) ID() string

func (*Socket) Off

func (s *Socket) Off(event string, fn func(args ...any)) *Socket

func (*Socket) On

func (s *Socket) On(event string, fn func(args ...any)) *Socket

type WebSocketAdapter

type WebSocketAdapter struct {
	// contains filtered or unexported fields
}

func NewWebSocketAdapter

func NewWebSocketAdapter(conn *websocket.Conn) *WebSocketAdapter

func (*WebSocketAdapter) Close

func (w *WebSocketAdapter) Close() error

func (*WebSocketAdapter) Receive

func (w *WebSocketAdapter) Receive() (Packet, error)

func (*WebSocketAdapter) Send

func (w *WebSocketAdapter) Send(pkt Packet) error