http

Documentation

Index

• func COPYCHAN[T any](done <-chan struct{}, src chan T) (generator func() (tap chan T, destructor func()))
• func CreateWsHandleFunc(ctx context.Context, subsystem WsSubsystem) func(conn *websocket.Conn)
• func ListenAndServe(ctx context.Context) error
• func Mux(ctx context.Context) http.Handler
• func RederWidgets(w http.ResponseWriter, r *http.Request)
• type LoggingHandler
  • func (h *LoggingHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type WsSubsystem

Functions

func COPYCHAN

func COPYCHAN[T any](done <-chan struct{}, src chan T) (
	generator func() (tap chan T, destructor func()),
)

func CreateWsHandleFunc

func CreateWsHandleFunc(ctx context.Context, subsystem WsSubsystem) func(conn *websocket.Conn)

func ListenAndServe

func ListenAndServe(ctx context.Context) error

func Mux

func Mux(ctx context.Context) http.Handler

func RederWidgets

func RederWidgets(w http.ResponseWriter, r *http.Request)

Types

type LoggingHandler

type LoggingHandler struct{ http.Handler }

func (*LoggingHandler) ServeHTTP

func (h *LoggingHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type WsSubsystem

type WsSubsystem interface {
	Dispatch(ctx context.Context, b []byte) error // receive event from obs browser html
	SendChan() chan string                        // channel from server to page
}

WsSubsystem - subsystem with chan for websocket