channel

README

Safe Channel

The library tries to remove some dangerous behaviors on normal channel:

• Write on a closed channel
• Close a closed channel

These above operations will be silently discarded.

Documentation

Index

• type Channel
  • func New() *Channel
  • func NewBufferedChannel(n int) *Channel
  • func (c *Channel) Close()
  • func (c *Channel) Publish(x interface{})
  • func (c *Channel) Watch() <-chan interface{}

Types

type Channel

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

Channel wraps the built-in channel and provide safe operations beyond it

func New

func New() *Channel

New creates a new Channel

func NewBufferedChannel

func NewBufferedChannel(n int) *Channel

NewBufferedChannel creates a buffered Channel

func (*Channel) Close

func (c *Channel) Close()

Close closes an active channel This method can be called many times without risks

func (*Channel) Publish

func (c *Channel) Publish(x interface{})

Publish sends an event to channel If channel is closed, Publish does nothing

func (*Channel) Watch

func (c *Channel) Watch() <-chan interface{}

Watch keeps listening on a channel