future

Documentation

Overview

Package future defines Future, a value which is determined some time in future.

Future is designed for writing long-running program which doing some works repeatedly like crawlers. It's good to be used as a broadcaster, or as a param to task generator.

ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt)
defer stop()
crawlerTask, pageFuture := downloadWebPage()
log.Print(task.Skip(
	task.Iter(
		crawlerTask,
		parseAndSavePage(pageFuture),
		task.Skip(
			notifyWebDash(pageFuture),
			cleanUpOldData(pageFuture),
		),
	).Timed(time.Minute).RetryN(3).Loop(),
	task.HTTPServer(myWebDash),
).Run(ctx))

Index

• type Future
  • func Create[T any]() (fut *Future[T], determine func(T, error))
  • func New[T any]() (fut *Future[T], res func(T), rej func(error))
  • func Reject[T any](e error) *Future[T]
  • func Resolve[T any](v T) *Future[T]
  • func (f *Future[T]) Await(ctx context.Context) (t T, err error)
  • func (f *Future[T]) Done() <-chan struct{}
  • func (f *Future[T]) Err() error
  • func (f *Future[T]) Get() T

Types

type Future

type Future[T any] struct {
	// contains filtered or unexported fields
}

Future represents a value which is determined some time in future.

func Create

func Create[T any]() (fut *Future[T], determine func(T, error))

Create creates a future fut, which can be resolved by determine.

Created future might have both the value and the error with non-empty value.

func New

func New[T any]() (fut *Future[T], res func(T), rej func(error))

New creates a future fut, which can be resolved by res or rejected by rej.

Created future will only have at most one non-empty value. If it is resolved by res, fut.Err() will be nil; fut.Get() returns empty value if rejected.

func Reject

func Reject[T any](e error) *Future[T]

Reject creates an already rejected future.

func Resolve

func Resolve[T any](v T) *Future[T]

Resolve creates an already resolved future.

func (*Future[T]) Await

func (f *Future[T]) Await(ctx context.Context) (t T, err error)

Await is a helper which waits the value and retrieves it along with the error.

func (*Future[T]) Done

func (f *Future[T]) Done() <-chan struct{}

Done returns a channel which is closed when value is determined.

func (*Future[T]) Err

func (f *Future[T]) Err() error

Err waits the value and retrieves the error.

func (*Future[T]) Get

func (f *Future[T]) Get() T

Get waits the value and retrieves it.