queue

Documentation

Index

• func Get(queue <-chan byte, number int) ([]byte, error)
• func Put(queue chan<- byte, items []byte)

Functions

func Get

func Get(queue <-chan byte, number int) ([]byte, error)

Get removes an exact number of items from the channel and blocks until that number of items are available. If the channel is closed then an error is returned.

func Put

func Put(queue chan<- byte, items []byte)

Put adds a slice of bytes to a channel queue. If the channel isn't buffered this will block.