Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Publisher ¶
type Publisher interface {
PublishMsg(msg []byte)
AddSubscriber(sub Subscriber)
}
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func (*Server) AddSubscriber ¶
func (s *Server) AddSubscriber(sub Subscriber)
Add a new suscriber to the server
func (*Server) BroadcastMsg ¶
Broadcast a message to all subscribers
type Subscriber ¶
type Subscriber interface {
SendMessage(msg []byte)
}
type WebSocketSubscriber ¶
type WebSocketSubscriber struct {
// contains filtered or unexported fields
}
func NewWebSocketSubscriber ¶
func NewWebSocketSubscriber(bufferSize int) *WebSocketSubscriber
func (*WebSocketSubscriber) SendMessage ¶
func (sub *WebSocketSubscriber) SendMessage(msg []byte)
Source Files
Click to show internal directories.
Click to hide internal directories.