channel

Documentation

Index

• type Broadcast
  • func NewBroadcast() *Broadcast
  • func (bc *Broadcast) Publish(b []byte)
  • func (bc *Broadcast) RegisterHandleFunc(id interface{}, handler func([]byte) []byte)
  • func (bc *Broadcast) SendToID(recvID, sendID interface{}, payload []byte)
  • func (bc *Broadcast) SendToIDResponse(recvID, sendID interface{}, payload []byte) []byte
  • func (bc *Broadcast) Subscribe(id interface{}, c chan []byte)
  • func (bc *Broadcast) SubscribeFunc(id interface{}, f func([]byte))
  • func (bc *Broadcast) Unsubscribe(id interface{})

Types

type Broadcast

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

func NewBroadcast

func NewBroadcast() *Broadcast

func (*Broadcast) Publish

func (bc *Broadcast) Publish(b []byte)

func (*Broadcast) RegisterHandleFunc

func (bc *Broadcast) RegisterHandleFunc(id interface{}, handler func([]byte) []byte)

func (*Broadcast) SendToID

func (bc *Broadcast) SendToID(recvID, sendID interface{}, payload []byte)

func (*Broadcast) SendToIDResponse

func (bc *Broadcast) SendToIDResponse(recvID, sendID interface{}, payload []byte) []byte

func (*Broadcast) Subscribe

func (bc *Broadcast) Subscribe(id interface{}, c chan []byte)

func (*Broadcast) SubscribeFunc

func (bc *Broadcast) SubscribeFunc(id interface{}, f func([]byte))

func (*Broadcast) Unsubscribe

func (bc *Broadcast) Unsubscribe(id interface{})