buffchan

Documentation

Index

• type BufferedChannel
  • func New() *BufferedChannel
  • func (b *BufferedChannel) Append(v interface{})
  • func (b *BufferedChannel) AsyncRemove() interface{}
  • func (b *BufferedChannel) Inspect() interface{}
  • func (b *BufferedChannel) Remove() interface{}

Types

type BufferedChannel

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

BufferedChannel provides go channel like interface with unlimited storage

func New

func New() *BufferedChannel

New Creates new buffer channel

func (*BufferedChannel) Append

func (b *BufferedChannel) Append(v interface{})

Append adds given data at end of channel

func (*BufferedChannel) AsyncRemove

func (b *BufferedChannel) AsyncRemove() interface{}

AsyncRemove removes first element of list asynchronously

func (*BufferedChannel) Inspect

func (b *BufferedChannel) Inspect() interface{}

Inspect first element of list if exists

func (*BufferedChannel) Remove

func (b *BufferedChannel) Remove() interface{}

Remove removes first element of list synchronously