يوضح هذا المثال كيفية استبدال بعض الكتل في الحدث، على سبيل المثال "تم تغيير المنشور بالمعرف 1" (تم التغيير بعد 1) وتشغيل تحميل المحتوى عبر طلب ajax على "الدردشة" حدث.

package main

import (
    "fmt"
    "net/http"
    "time"

    "github.com/r3labs/sse/v2"
)

func main() {
    server := sse.New()
    _ = server.CreateStream("messages")

    mux := http.NewServeMux()
    mux.HandleFunc("/events", func(w http.ResponseWriter, r *http.Request) {

        // la security
        token := r.URL.Query().Get("token")
        if token != "secret" {
            http.Error(w, "invalid token", http.StatusUnauthorized)
            return
        }
        go func() {
            Hello from chat room`))
    })

    mux.HandleFunc("/index", func(w http.ResponseWriter, r *http.Request) {
        w.Write([]byte(`
        
        
        

            
one
        
        

            
one
        
        

            
one
        
        

            
one
        
        

            

                chat body reloaded
            
        
        
        `))
    })

    go func() {
        i := 0
        for {
            i  
            time.Sleep(1 * time.Second)

            server.TryPublish("messages", &sse.Event{
                ID:    []byte(fmt.Sprintf("%d", i)),
                Event: []byte("post-1-changed"),
                Data:  []byte(`
Hello from sse `   fmt.Sprintf("%d", i)   `
`),
            })

            server.TryPublish("messages", &sse.Event{
                ID:    []byte(fmt.Sprintf("%d", i)),
                Event: []byte("notifications"),
                Data:  []byte(`
Hello from post 2 sse `   fmt.Sprintf("%d", i)   `
`),
            })

            server.TryPublish("messages", &sse.Event{
                ID:    []byte(fmt.Sprintf("%d", i)),
                Event: []byte("chatter"),
                Data:  []byte(`
`),
            })
            server.EventTTL = 5 * time.Second
        }
    }()

    http.ListenAndServe(":9999", mux)
}