concurrent

Documentation

Index

• func HeaderConcurrent() string
• func Load(env types.EnvType)
• type Atom
  • func (a *Atom) Deref(_ context.Context) (MalType, error)
  • func (a *Atom) LispPrint(pr_str func(MalType, bool) string) string
  • func (a *Atom) Set(val MalType) MalType
  • func (a *Atom) Type() string
• type Future
  • func NewFuture(ctx context.Context, fn MalFunc) *Future
  • func (f *Future) Cancel() bool
  • func (f *Future) Deref(ctx context.Context) (MalType, error)
  • func (f *Future) GetPosition() *Position
  • func (f *Future) LispPrint(_Pr_str func(MalType, bool) string) string
  • func (f *Future) Type() string

Functions

func HeaderConcurrent

func HeaderConcurrent() string

func Load

func Load(env types.EnvType)

Types

type Atom

type Atom struct {
	Mutex  sync.RWMutex
	Val    MalType
	Meta   MalType
	Cursor *Position
}

Atoms

func (*Atom) Deref

func (a *Atom) Deref(_ context.Context) (MalType, error)

func (*Atom) LispPrint

func (a *Atom) LispPrint(pr_str func(MalType, bool) string) string

func (*Atom) Set

func (a *Atom) Set(val MalType) MalType

func (*Atom) Type

func (a *Atom) Type() string

type Future

type Future struct {
	ValChan    chan MalType
	ErrChan    chan error
	CancelFunc context.CancelFunc
	Done       bool
	Cancelled  bool

	Fn     MalFunc
	Meta   MalType
	Cursor *Position
}

Future

func NewFuture

func NewFuture(ctx context.Context, fn MalFunc) *Future

func (*Future) Cancel

func (f *Future) Cancel() bool

func (*Future) Deref

func (f *Future) Deref(ctx context.Context) (MalType, error)

func (*Future) GetPosition

func (f *Future) GetPosition() *Position

func (*Future) LispPrint

func (f *Future) LispPrint(_Pr_str func(MalType, bool) string) string

func (*Future) Type

func (f *Future) Type() string