channels

Documentation

Index

• func Subscribe(fanout *Fanout, sub ...*SafeChannel)
• func Unsubscribe(fanout *Fanout, sub ...*SafeChannel)
• type Fanout
  • func NewFanout(pub *SafeChannel) *Fanout
  • func (fanout *Fanout) NewSubscriber(size ...int) *SafeChannel
  • func (fanout *Fanout) Start()
  • func (fanout *Fanout) Stop()
  • func (fanout *Fanout) SubChan() <-chan *SafeChannel
  • func (fanout *Fanout) Subscribe(sub ...*SafeChannel)
  • func (fanout *Fanout) Unsubscribe(sub *SafeChannel)
• type SafeChannel
  • func NewSafeChannel(size ...int) *SafeChannel
  • func WrapSafeChannel(c chan T) *SafeChannel
  • func (me *SafeChannel) IsClosed() bool
  • func (me *SafeChannel) SafeClose()
  • func (me *SafeChannel) SafeSend(value T) bool
• type T

Functions

func Subscribe

func Subscribe(fanout *Fanout, sub ...*SafeChannel)

func Unsubscribe

func Unsubscribe(fanout *Fanout, sub ...*SafeChannel)

Types

type Fanout

type Fanout struct {
	sync.Once
	sync.Mutex
	// contains filtered or unexported fields
}

func NewFanout

func NewFanout(pub *SafeChannel) *Fanout

func (*Fanout) NewSubscriber

func (fanout *Fanout) NewSubscriber(size ...int) *SafeChannel

func (*Fanout) Start

func (fanout *Fanout) Start()

func (*Fanout) Stop

func (fanout *Fanout) Stop()

func (*Fanout) SubChan

func (fanout *Fanout) SubChan() <-chan *SafeChannel

func (*Fanout) Subscribe

func (fanout *Fanout) Subscribe(sub ...*SafeChannel)

func (*Fanout) Unsubscribe

func (fanout *Fanout) Unsubscribe(sub *SafeChannel)

type SafeChannel

type SafeChannel struct {
	C chan T
	// contains filtered or unexported fields
}

func NewSafeChannel

func NewSafeChannel(size ...int) *SafeChannel

func WrapSafeChannel

func WrapSafeChannel(c chan T) *SafeChannel

func (*SafeChannel) IsClosed

func (me *SafeChannel) IsClosed() bool

func (*SafeChannel) SafeClose

func (me *SafeChannel) SafeClose()

func (*SafeChannel) SafeSend

func (me *SafeChannel) SafeSend(value T) bool

type T

type T interface{}