listener

Documentation

Index

• func SocketListen(ctx context.Context, log zerolog.Logger, con *websocket.Conn) <-chan []byte

Functions

func SocketListen

func SocketListen(ctx context.Context, log zerolog.Logger, con *websocket.Conn) <-chan []byte

SocketListen Separate goroutine to listen WS connection, exposing channel for received data (was required to be able to release connection when gracefully shut down, since ReadMessage() is blocking)