sseflow

package module

v0.0.3 Latest Latest Go to latest Published: Jan 26, 2025 License: MIT Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewClient(ctx context.Context, r *http.Response) (*Client, error)

func (cl *Client) Close() error

func (cl *Client) Listen(ctx context.Context) <-chan *Message

func (cl *Client) Start()

type ErrClosed struct {
	Retry uint
	ID    string
}

func (err *ErrClosed) Error() string

func (err *ErrClosed) GetRetry() time.Duration

type Message struct {
	Comment []string
	ID      *string
	Retry   uint
	Event   string
	Data    string
}

func (msg *Message) Write(b []byte) (int, error)

func (msg *Message) WriteTo(w io.Writer) (n int64, _ error)

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

func Upgrade(w http.ResponseWriter, r *http.Request) *Server

func (srv *Server) Close() error

func (srv *Server) Deadline() (deadline time.Time, ok bool)

func (srv *Server) Done() <-chan struct{}

func (srv *Server) Err() error

func (srv *Server) Push(v ...*Message)

func (srv *Server) Value(k any) any