udwChan

Documentation

Index

• type Chan
  • func MakeChan(bufferSize int) *Chan
  • func (c *Chan) Close()
  • func (c *Chan) GetReceiveCh() <-chan interface{}
  • func (c *Chan) IsClosed() bool
  • func (c *Chan) Receive() (data interface{}, isClose bool)
  • func (c *Chan) Send(data interface{}) (isClose bool)
  • func (c *Chan) SendIfEmpty(data interface{}) (isClose bool, isSuccess bool)
• type ChanBytes
  • func MakeChanBytes(bufferSize int) *ChanBytes
  • func (c *ChanBytes) Close()
  • func (c *ChanBytes) GetReceiveCh() <-chan []byte
  • func (c *ChanBytes) IsClosed() bool
  • func (c *ChanBytes) Receive() (data []byte, isClose bool)
  • func (c *ChanBytes) Send(data []byte) (isClose bool)
  • func (c *ChanBytes) SendIfEmpty(data []byte) (isClose bool, isSuccess bool)

Types

type Chan

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

func MakeChan

func MakeChan(bufferSize int) *Chan

func (*Chan) Close

func (c *Chan) Close()

func (*Chan) GetReceiveCh

func (c *Chan) GetReceiveCh() <-chan interface{}

func (*Chan) IsClosed

func (c *Chan) IsClosed() bool

func (*Chan) Receive

func (c *Chan) Receive() (data interface{}, isClose bool)

func (*Chan) Send

func (c *Chan) Send(data interface{}) (isClose bool)

func (*Chan) SendIfEmpty

func (c *Chan) SendIfEmpty(data interface{}) (isClose bool, isSuccess bool)

type ChanBytes

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

func MakeChanBytes

func MakeChanBytes(bufferSize int) *ChanBytes

func (*ChanBytes) Close

func (c *ChanBytes) Close()

func (*ChanBytes) GetReceiveCh

func (c *ChanBytes) GetReceiveCh() <-chan []byte

func (*ChanBytes) IsClosed

func (c *ChanBytes) IsClosed() bool

func (*ChanBytes) Receive

func (c *ChanBytes) Receive() (data []byte, isClose bool)

func (*ChanBytes) Send

func (c *ChanBytes) Send(data []byte) (isClose bool)

func (*ChanBytes) SendIfEmpty

func (c *ChanBytes) SendIfEmpty(data []byte) (isClose bool, isSuccess bool)