broadcaster

Documentation

Index

• type Broadcaster
  • func (b *Broadcaster) Subscribe(ctx context.Context, connect ConnectFunc) (<-chan interface{}, error)
• type ConnectFunc

Types

type Broadcaster

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

func (*Broadcaster) Subscribe

func (b *Broadcaster) Subscribe(ctx context.Context, connect ConnectFunc) (<-chan interface{}, error)

type ConnectFunc

type ConnectFunc func() (chan interface{}, error)