stream

Documentation

Index

• type Pusher
  • func StartPusher(w http.ResponseWriter) (*Pusher, error)
  • func (p *Pusher) Push(data interface{}) error
• type Receiver
  • func StartReceiver(src io.Reader) *Receiver
  • func (r *Receiver) Recieve(into interface{}) error
• type WriterFlusher

Types

type Pusher

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

func StartPusher

func StartPusher(w http.ResponseWriter) (*Pusher, error)

func (*Pusher) Push

func (p *Pusher) Push(data interface{}) error

type Receiver

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

func StartReceiver

func StartReceiver(src io.Reader) *Receiver

func (*Receiver) Recieve

func (r *Receiver) Recieve(into interface{}) error

type WriterFlusher

type WriterFlusher interface {
	http.Flusher
	io.Writer
}