pivo

type Connector interface {
	Close(error) error
	Protocol() string
	RemoteAddr() net.Addr
	Send(*Message) error
}

type Hub struct {
	// The interval at which new connections are processed.
	// A Duration of time.Second / 100 would mean hundred
	// of new connections are processed in a second.
	JoinLimitRateInterval time.Duration

	// The size of the burst allowed when the join rate limit
	// is reached. A value of 10 would mean that 10 extra
	// connections may wait to join the hub.
	JoinLimitRateBurst uint

	// The maximum number of new connections waiting to
	// join the hub before ErrJoinQueueIsFull is being
	// thrown.
	JoinMaxQueueSize uint
	// contains filtered or unexported fields
}

type Message struct {
	Data []byte    // Bytes of data
	From Connector // Original connector
	Type int       // Type of data
}

type OnBinaryReadCloser interface {
	OnBinaryReader
	OnCloser
}

type OnBinaryReader interface {
	OnBinaryRead([]byte) error
}

type OnCloser interface {
	OnClose(error) error
}

type OnHubBroadcaster interface {
	OnHubBroadcast(*Message) (Ports, error)
}

type OnHubCloser interface {
	OnHubClose(Ports)
}

type OnHubJoiner interface {
	OnHubJoin(Connector) error
}

type OnHubLeaver interface {
	OnHubLeave(Connector)
}

type OnReadCloser interface {
	OnCloser
	OnReader
}

type OnReader interface {
	OnBinaryReader
	OnTextReader
}

type OnTextReadCloser interface {
	OnTextReader
	OnCloser
}

type OnTextReader interface {
	OnTextRead(string) error
}

type Port chan *Message

type Ports map[Connector]bool