websocket

package

v0.8.0 Latest Latest Go to latest Published: Oct 21, 2025 License: MIT Imports: 18 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrNotImplemented = errors.New("operation not implemented")
	ErrNoErrorHandled = errors.New("handled")
)

View Source

var BufferSize = 100

func Dial[T any](
	url *url.URL,
	ctx context.Context,
) (readerOut <-chan T, writerOut chan<- Write[T], err error)

func Serve[T any](acceptFunc func(r *http.Request) bool, wsfunc WSHandler[T]) http.HandlerFunc

func ServeFiber[T any](
	r fiber.Router,
	path string,
	acceptFunc func(c *fiber.Ctx) error,
	wsfunc WSHandler[T],
)

type WSHandler[T any] func(<-chan T, chan<- Write[T], *http.Request, context.Context)

type Write[T any] struct {
	Data T            `json:"data"`
	Err  chan<- error `json:"err"`
}