transport

type Codec struct {
	eiop.PacketEncoder
	eiop.PacketDecoder
	eiop.PayloadEncoder
	eiop.PayloadDecoder
}

type HTTPCompressionKind string

type Name string

type Option = with.Option

type OptionWith = with.OptionWith

type PollingTransport struct {
	*Transport
	// contains filtered or unexported fields
}

type SessionID = eios.ID

type StartWriteBuffer func() bool

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

type Transporter interface {
	ID() SessionID
	Name() Name
	Send(eiop.Packet)
	Receive() <-chan eiop.Packet
	SendTimeout()
	ReceiveTimeout() <-chan SessionID
	Run(http.ResponseWriter, *http.Request, ...Option) error

	Shutdown()
}

type WaitGroup interface {
	Add(int)
	Done()
	Wait()
}

type WebsocketTransport struct {
	*Transport

	PingMsg string
	// contains filtered or unexported fields
}

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