polling

Documentation

Index

• Variables
• func MakeSendChan() chan bool
• func NewClient(r *http.Request) (transport.Client, error)
• func NewServer(w http.ResponseWriter, r *http.Request, callback transport.Callback) (transport.Server, error)
• type Locker
  • func NewLocker() *Locker
  • func (l *Locker) Lock()
  • func (l *Locker) TryLock() bool
  • func (l *Locker) Unlock()
• type Polling
  • func (p *Polling) Close() error
  • func (p *Polling) NextWriter(msgType message.MessageType, packetType parser.PacketType) (io.WriteCloser, error)
  • func (p *Polling) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Writer
  • func NewWriter(w io.WriteCloser, server *Polling) *Writer
  • func (w *Writer) Close() error

Variables

var Creater = transport.Creater{
	Name:      "polling",
	Upgrading: false,
	Server:    NewServer,
	Client:    NewClient,
}

Functions

func MakeSendChan

func MakeSendChan() chan bool

func NewClient

func NewClient(r *http.Request) (transport.Client, error)

func NewServer

func NewServer(w http.ResponseWriter, r *http.Request, callback transport.Callback) (transport.Server, error)

Types

type Locker

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

func NewLocker

func NewLocker() *Locker

func (*Locker) Lock

func (l *Locker) Lock()

func (*Locker) TryLock

func (l *Locker) TryLock() bool

func (*Locker) Unlock

func (l *Locker) Unlock()

type Polling

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

func (*Polling) Close

func (p *Polling) Close() error

func (*Polling) NextWriter

func (p *Polling) NextWriter(msgType message.MessageType, packetType parser.PacketType) (io.WriteCloser, error)

func (*Polling) ServeHTTP

func (p *Polling) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Writer

type Writer struct {
	io.WriteCloser
	// contains filtered or unexported fields
}

func NewWriter

func NewWriter(w io.WriteCloser, server *Polling) *Writer

func (*Writer) Close

func (w *Writer) Close() error