sse

Documentation

Index

• type Handler
  • func New(s session.Handler) *Handler
  • func (h *Handler) Broadcast(message string)
  • func (h *Handler) Send(chanid, message string)
  • func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Message
  • func Msg() Message
  • func (m Message) Data(lines ...string) Message
  • func (m Message) End() string
  • func (m Message) Event(name string) Message
  • func (m Message) Id(id string) Message
  • func (m Message) Retry(n int) Message

Types

type Handler

type Handler struct {
	Session session.Handler

	Channels map[string]chan string
	// contains filtered or unexported fields
}

func New

func New(s session.Handler) *Handler

func (*Handler) Broadcast

func (h *Handler) Broadcast(message string)

func (*Handler) Send

func (h *Handler) Send(chanid, message string)

func (*Handler) ServeHTTP

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

type Message

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

func Msg

func Msg() Message

func (Message) Data

func (m Message) Data(lines ...string) Message

func (Message) End

func (m Message) End() string

func (Message) Event

func (m Message) Event(name string) Message

func (Message) Id

func (m Message) Id(id string) Message

func (Message) Retry

func (m Message) Retry(n int) Message