channels

package

v1.3.8 Latest Latest Go to latest Published: Jul 29, 2022 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Queue provides a factory to queue channels sequentially and pop / signal them one at a time in a daisy chain.

func (q *Queue) Any() (any bool)

Any will return true if there are any current channels waiting.

func (q *Queue) Signal(x interface{})

Signal will only signal the first item in the queue.

func (q *Queue) Wait(x interface{}) (c chan interface{}, any bool)

Wait will return a channel for your function to wait on.