mq

Documentation

Index

• type Observer
  • func NewObserver() *Observer
  • func (bs *Observer) Listener() chan int
  • func (bs *Observer) RemoveListener(ch chan int)
  • func (bs *Observer) Run() chan int

Types

type Observer

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

func NewObserver

func NewObserver() *Observer

NewObserver 创建一个广播服务

func (*Observer) Listener

func (bs *Observer) Listener() chan int

Listener 这会创建一个新消费者并返回一个监听通道

func (*Observer) RemoveListener

func (bs *Observer) RemoveListener(ch chan int)

RemoveListener 移除一个消费者

func (*Observer) Run

func (bs *Observer) Run() chan int