empsc

Documentation

Index

• type Channel
  • func New(c Consumer, opts ...ChannelOpt) Channel
• type ChannelOpt
  • func ChannelBufSize(size int) ChannelOpt
• type Consumer
• type Producer

Types

type Channel

type Channel interface {
	eidiom.Closer

	// Producer Create a new producer
	Producer() Producer
}

func New

func New(c Consumer, opts ...ChannelOpt) Channel

type ChannelOpt

type ChannelOpt func(o channelOpts) channelOpts

func ChannelBufSize

func ChannelBufSize(size int) ChannelOpt

type Consumer

type Consumer func(v interface{}) (err error)

type Producer

type Producer interface {
	// Send a value to the consumer. This func will block if a channel is full.
	Send(v interface{})
}

Producer of Multi producer, single consumer