hub

README

hub

Golang chan broadcasting library.

See original stackoverflow answer.

Documentation

Index

• type Hub
  • func NewHub() *Hub
  • func (h *Hub) Done()
  • func (h *Hub) DoneWithContext(ctx context.Context)
  • func (h *Hub) Init()
  • func (h *Hub) Pub(msg interface{})
  • func (h *Hub) PubWithContext(ctx context.Context, msg interface{})
  • func (h *Hub) Start(ctx context.Context)
  • func (h *Hub) Stop()
  • func (h *Hub) StopNonBlock()
  • func (h *Hub) StopWithContext(ctx context.Context)
  • func (h *Hub) Sub(capacity int) (sub chan interface{})
  • func (h *Hub) SubWithContext(ctx context.Context, capacity int) (sub chan interface{})
  • func (h *Hub) Unsub(sub chan interface{})
  • func (h *Hub) UnsubNonBlock(sub chan interface{})
  • func (h *Hub) UnsubWithContext(ctx context.Context, sub chan interface{})
  • func (h *Hub) UnsubWithTimeout(sub chan interface{}, timeout time.Duration)

Types

type Hub

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

func NewHub

func NewHub() *Hub

func (*Hub) Done

func (h *Hub) Done()

func (*Hub) DoneWithContext

func (h *Hub) DoneWithContext(ctx context.Context)

func (*Hub) Init

func (h *Hub) Init()

func (*Hub) Pub

func (h *Hub) Pub(msg interface{})

func (*Hub) PubWithContext

func (h *Hub) PubWithContext(ctx context.Context, msg interface{})

func (*Hub) Start

func (h *Hub) Start(ctx context.Context)

func (*Hub) Stop

func (h *Hub) Stop()

func (*Hub) StopNonBlock

func (h *Hub) StopNonBlock()

func (*Hub) StopWithContext

func (h *Hub) StopWithContext(ctx context.Context)

func (*Hub) Sub

func (h *Hub) Sub(capacity int) (sub chan interface{})

func (*Hub) SubWithContext

func (h *Hub) SubWithContext(ctx context.Context, capacity int) (sub chan interface{})

func (*Hub) Unsub

func (h *Hub) Unsub(sub chan interface{})

func (*Hub) UnsubNonBlock

func (h *Hub) UnsubNonBlock(sub chan interface{})

func (*Hub) UnsubWithContext

func (h *Hub) UnsubWithContext(ctx context.Context, sub chan interface{})

func (*Hub) UnsubWithTimeout

func (h *Hub) UnsubWithTimeout(sub chan interface{}, timeout time.Duration)