topic

Documentation

Index

• type Receiver
• type Topic
  • func New() *Topic
  • func (t *Topic) Close()
  • func (t *Topic) Out() chan<- interface{}
  • func (t *Topic) Send(m interface{})
  • func (t *Topic) Sub(ctx context.Context, rx Receiver) error

Types

type Receiver

type Receiver chan interface{}

Receiver is able to receive broadcast messages

type Topic

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

Topic is for broadcasting

func New

func New() *Topic

New makes a Topic

func (*Topic) Close

func (t *Topic) Close()

Close closes all associated channels in and out

func (*Topic) Out

func (t *Topic) Out() chan<- interface{}

Out gives access to the broadcast channel

func (*Topic) Send

func (t *Topic) Send(m interface{})

Send broadcasts to all receivers

func (*Topic) Sub

func (t *Topic) Sub(ctx context.Context, rx Receiver) error

Sub subscribes a receiver