publisher

type Client interface {
	HandleMessage(ctx context.Context, msg funcie.Message) error
	Close() error
}

type ClientListener interface {
	ServeHTTP(w http.ResponseWriter, r *http.Request)
}

type ClientManager interface {
	AddClient(conn Client)
	CloseAllClients()
	AddClientRouting(id string, conn Client)
	RemoveClientRouting(id string)
	GetClientRouting(id string) (Client, error)
	Process(ctx context.Context, conn Websocket)
}

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

type Websocket interface {
	Close(code ws.StatusCode, reason string) error
	Read(ctx context.Context) (ws.MessageType, []byte, error)
	Write(ctx context.Context, typ ws.MessageType, p []byte) error
	Subprotocol() string
}

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

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

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

type WebsocketServer interface {
	Accept(w http.ResponseWriter, r *http.Request, opts *ws.AcceptOptions) (Websocket, error)
}

type WebsocketServerWrapper struct{}