sse

Documentation

Index

• Constants
• Variables
• func NewRequest(uri string) (*http.Request, error)
• func Wrap(fn http.HandlerFunc) http.HandlerFunc
• type Message
  • func NewErrMessage(id, data string) *Message
  • func NewMessage(id, event, data string) *Message
  • func TransferMessage(content []byte) (*Message, error)
  • func (m *Message) Send(w http.ResponseWriter)

Constants

const ContentType = "text/event-stream"

Variables

var EOFMessage = NewMessage("", "error", "eof")

var NewEventStreamReader = sse.NewEventStreamReader

Functions

func NewRequest

func NewRequest(uri string) (*http.Request, error)

func Wrap

func Wrap(fn http.HandlerFunc) http.HandlerFunc

Types

type Message

type Message struct {
	ID    string
	Event string
	Data  string
}

func NewErrMessage

func NewErrMessage(id, data string) *Message

func NewMessage

func NewMessage(id, event, data string) *Message

func TransferMessage

func TransferMessage(content []byte) (*Message, error)

func (*Message) Send

func (m *Message) Send(w http.ResponseWriter)