async

Documentation

Index

• Variables
• type Service
  • func New(ctx context.Context, name string, size int, timeout time.Duration) *Service
  • func (s *Service) Await(f func() (any, error)) (res any, err error)
  • func (s *Service) Get() <-chan func()
  • func (s *Service) Name() string
  • func (s *Service) Send(f func() (any, error)) (err error)

Variables

var (
	ErrServiceChanFull     = errors.New("async: service chan is full")
	ErrServiceAwaitTimeout = errors.New("async: service await timeout")
)

Types

type Service

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

func New

func New(ctx context.Context, name string,
	size int, timeout time.Duration) *Service

func (*Service) Await

func (s *Service) Await(f func() (any, error)) (res any, err error)

func (*Service) Get

func (s *Service) Get() <-chan func()

func (*Service) Name

func (s *Service) Name() string

func (*Service) Send

func (s *Service) Send(f func() (any, error)) (err error)