pipe

Documentation

Index

• type AnySupply
  • func MakeAnySupplyBuff(cap int) *AnySupply
  • func MakeAnySupplyChan() *AnySupply
  • func (c *AnySupply) Cap() int
  • func (c *AnySupply) Close()
  • func (c *AnySupply) Len() int
  • func (c *AnySupply) Provide(dat anyThing)
  • func (c *AnySupply) Receive() (dat anyThing)
  • func (c *AnySupply) Request() (dat anyThing, open bool)

Types

type AnySupply

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

AnySupply is a supply channel

func MakeAnySupplyBuff

func MakeAnySupplyBuff(cap int) *AnySupply

MakeAnySupplyBuff returns a (pointer to a) fresh buffered (with capacity=`cap`) supply channel

func MakeAnySupplyChan

func MakeAnySupplyChan() *AnySupply

MakeAnySupplyChan returns a (pointer to a) fresh unbuffered supply channel

func (*AnySupply) Cap

func (c *AnySupply) Cap() int

Cap reports the capacity of the underlying anyThing channel

func (*AnySupply) Close

func (c *AnySupply) Close()

Close closes the underlying anyThing channel

func (*AnySupply) Len

func (c *AnySupply) Len() int

Len reports the length of the underlying anyThing channel

func (*AnySupply) Provide

func (c *AnySupply) Provide(dat anyThing)

Provide is the send method - aka "myAnyChan <- myAny"

func (*AnySupply) Receive

func (c *AnySupply) Receive() (dat anyThing)

Receive is the receive operator as method - aka "myAny := <-myAnyChan"

func (*AnySupply) Request

func (c *AnySupply) Request() (dat anyThing, open bool)

Request is the comma-ok multi-valued form of Receive and reports whether a received value was sent before the anyThing channel was closed