Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrClosed = errors.New("PriorityChannel Closed")
)
Functions ¶
This section is empty.
Types ¶
type PriorityChannel ¶
PriorityChannel as implemented by a min heap ie. the 0th element is the *lowest* value.
func New ¶
func New(capacity int) *PriorityChannel
New creates a PriorityChannel of the given capacity.
func (*PriorityChannel) Close ¶
func (pc *PriorityChannel) Close()
func (*PriorityChannel) Len ¶
func (pc *PriorityChannel) Len() int
Len return length of priority queue
func (*PriorityChannel) Put ¶
func (pc *PriorityChannel) Put(val Prioritor) error
func (*PriorityChannel) Reader ¶
func (pc *PriorityChannel) Reader() <-chan Prioritor
Click to show internal directories.
Click to hide internal directories.