actor

package

v0.0.3 Latest Latest Go to latest Published: Jul 16, 2023 License: Apache-2.0, BSD-3-Clause, ISC Imports: 3 Imported by: 0

Details

This section is empty.

View Source

var ErrActorDead = errors.New("actor dead")

View Source

var ErrClosed = errors.New("promise closed")

This section is empty.

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

func (b *Base[T]) Active() bool

Active returns true if the task is currently running. Note that by the time this function returns, the value it returns may already be stale.

func (b *Base[T]) Err() error

Err returns the last error, if a task returns one.

func (b *Base[T]) Send(ctx context.Context, value T) (*Promise[any], error)

Send will block until the message is sent or the context is cancelled.

func (b *Base[T]) Shutdown(ctx context.Context) error

Shutdown shuts down the task, if it's running. Shutdown will wait for the current instance of the task to fully shut down.

func (b *Base[T]) TrySend(ctx context.Context, value T) (*Promise[any], bool)

TrySend tries to send if it wouldn't block. The boolean result is set to true when the message is successfully sent, false otherwise.

func (b *Base[T]) TryStart(ctx context.Context, callback func(context.Context, *Task[T]) error) bool

TryStart returns true if started, or false if there's already a running task.

type Message[T any] struct {
	Context context.Context
	Value   T
	Promise *Promise[any]
}

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

Promise is a simple promise-like object.

func NewPromise[T any]() *Promise[T]

func (p *Promise[T]) Close()

func (p *Promise[T]) Reject(err error)

func (p *Promise[T]) Resolve(value T)

func (p *Promise[T]) Wait(ctx context.Context) (T, error)

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

func (t *Task[T]) Receive() (Message[T], error)

Receive receives the next message in the mailbox. Note that the promise needs to be resolved or rejected for every message.