parallelize

Documentation

Index

• func Until(ctx context.Context, pieces int, doWorkPiece func(i int) error) error
• type ErrorChannel
  • func NewErrorChannel() *ErrorChannel
  • func (e *ErrorChannel) Receive() error
  • func (e *ErrorChannel) SendError(err error)

Functions

func Until

func Until(ctx context.Context, pieces int, doWorkPiece func(i int) error) error

Types

type ErrorChannel

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

ErrorChannel supports non-blocking send and receive operation to capture error. A maximum of one error is kept in the channel and the rest of the errors sent are ignored, unless the existing error is received and the channel becomes empty again.

func NewErrorChannel

func NewErrorChannel() *ErrorChannel

func (*ErrorChannel) Receive

func (e *ErrorChannel) Receive() error

func (*ErrorChannel) SendError

func (e *ErrorChannel) SendError(err error)