iterator

Documentation

Index

• Variables
• type Iterator
  • func New(cxt context.Context, buf int) *Iterator
  • func (t *Iterator) Close() error
  • func (t *Iterator) Next() (interface{}, error)
  • func (t *Iterator) Write(r Result) error
• type Result

Variables

var (
	ErrClosed    = errors.New("Closed")
	ErrCancelled = errors.New("Cancelled")
)

Types

type Iterator

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

func New

func New(cxt context.Context, buf int) *Iterator

func (*Iterator) Close

func (t *Iterator) Close() error

func (*Iterator) Next

func (t *Iterator) Next() (interface{}, error)

func (*Iterator) Write

func (t *Iterator) Write(r Result) error

type Result

type Result struct {
	Elem  interface{}
	Error error
}