batch

Documentation

Index

• type Batch
  • func New[B any](ctx context.Context) (*Batch[B], context.Context)
  • func (b *Batch[B]) Go(fn func() (B, error))
  • func (b *Batch[B]) Size() int
  • func (b *Batch[B]) Wait() ([]B, error)

Types

type Batch

type Batch[B any] struct {
	// contains filtered or unexported fields
}

func New

func New[B any](ctx context.Context) (*Batch[B], context.Context)

func (*Batch[B]) Go

func (b *Batch[B]) Go(fn func() (B, error))

func (*Batch[B]) Size

func (b *Batch[B]) Size() int

func (*Batch[B]) Wait

func (b *Batch[B]) Wait() ([]B, error)