go-multicast

package provide multicast sending messages to all connected clients

Usage:

package main

import (
	"context"
	"github.com/asmyasnikov/go-multicast"
	"github.com/asmyasnikov/go-multicast/helpers/websocket"
	"net/http"
	"fmt"
	"time"
)

func main() {
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	m := multicast.New(
		ctx,
		func(err error) {
			fmt.Println(err)
		},
		nil, // latest message replace snapshot
		time.Second,
	)
	go func() {
		for {
			m.SendAll(time.Now())
			time.Sleep(time.Millisecond * 100)
		}
	}()
	http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
		conn, err := websocket.Upgrader.Upgrade(w, r, nil)
		if err != nil {
			fmt.Println(err)
			return
		}
		websocket.Add(
			m,
			conn,
			nil,
		)
	})
	if err := http.ListenAndServe(":80", nil); err != nil {
		fmt.Println(err)
	}
}