Versions in this module Expand all Collapse all v0 v0.0.3 Jul 16, 2023 v0.0.2 Jun 19, 2023 Changes in this version + var ErrActorDead = errors.New("actor dead") + var ErrClosed = errors.New("promise closed") + type Base struct + func (b *Base[T]) Active() bool + func (b *Base[T]) Err() error + func (b *Base[T]) Send(ctx context.Context, value T) (*Promise[any], error) + func (b *Base[T]) Shutdown(ctx context.Context) error + func (b *Base[T]) TrySend(ctx context.Context, value T) (*Promise[any], bool) + func (b *Base[T]) TryStart(ctx context.Context, callback func(context.Context, *Task[T]) error) bool + type Message struct + Context context.Context + Promise *Promise[any] + Value T + type Promise struct + 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 struct + func (t *Task[T]) Receive() (Message[T], error)
Go to main page