gxchan

Documentation

Index

• type UnboundedChan
  • func NewUnboundedChan(capacity int) *UnboundedChan
  • func NewUnboundedChanWithQuota(capacity, quota int) *UnboundedChan
  • func (ch *UnboundedChan) Cap() int
  • func (ch *UnboundedChan) In() chan<- interface{}
  • func (ch *UnboundedChan) Len() int
  • func (ch *UnboundedChan) Out() <-chan interface{}

Types

type UnboundedChan

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

UnboundedChan is a chan that could grow if the number of elements exceeds the capacity.

func NewUnboundedChan

func NewUnboundedChan(capacity int) *UnboundedChan

NewUnboundedChan creates an instance of UnboundedChan.

func NewUnboundedChanWithQuota

func NewUnboundedChanWithQuota(capacity, quota int) *UnboundedChan

func (*UnboundedChan) Cap

func (ch *UnboundedChan) Cap() int

Cap returns the total capacity of chan.

func (*UnboundedChan) In

func (ch *UnboundedChan) In() chan<- interface{}

In returns write-only chan

func (*UnboundedChan) Len

func (ch *UnboundedChan) Len() int

Len returns the total length of chan

func (*UnboundedChan) Out

func (ch *UnboundedChan) Out() <-chan interface{}

Out returns read-only chan