ioqueue

Documentation

Index

• func ReleaseData(r *Data)
• type Data
  • func NewData() *Data
• type IOQueue
  • func New() *IOQueue
  • func (q *IOQueue) Close()
  • func (q *IOQueue) SignalWantsClose()
  • func (q *IOQueue) State() (closed, wantsClose bool)

Functions

func ReleaseData

func ReleaseData(r *Data)

Types

type Data

type Data struct {
	Data []byte
	Err  error
	// contains filtered or unexported fields
}

func NewData

func NewData() *Data

type IOQueue

type IOQueue struct {
	C chan *Data
	// contains filtered or unexported fields
}

func New

func New() *IOQueue

func (*IOQueue) Close

func (q *IOQueue) Close()

func (*IOQueue) SignalWantsClose

func (q *IOQueue) SignalWantsClose()

func (*IOQueue) State

func (q *IOQueue) State() (closed, wantsClose bool)