Versions in this module Expand all Collapse all v0 v0.12.2 Mar 18, 2021 Changes in this version + var ErrServerShuttingDown = errors.New("subscription server shutting down") + type Client struct + func (c *Client) Cancel() + func (c *Client) Quit() <-chan struct{} + func (c *Client) Updates() <-chan interface{} + type Server struct + func NewServer() *Server + func (s *Server) SendUpdate(update interface{}) error + func (s *Server) Start() error + func (s *Server) Stop() error + func (s *Server) Subscribe() (*Client, error) + type Subscription interface + Cancel func() + Quit func() <-chan struct{} + Updates func() <-chan interface{}
Go to main page