delay

Documentation

Index

• type Chan
  • func NewChan(ctx context.Context, fn func(k, v interface{}), delay time.Duration) *Chan
  • func (c *Chan) Close() error
  • func (c *Chan) Put(v interface{})
  • func (c *Chan) PutKey(k string, v interface{})

Types

type Chan

type Chan struct {
	Map *sync.Map
	// contains filtered or unexported fields
}

func NewChan

func NewChan(ctx context.Context, fn func(k, v interface{}), delay time.Duration) *Chan

func (*Chan) Close

func (c *Chan) Close() error

func (*Chan) Put

func (c *Chan) Put(v interface{})

func (*Chan) PutKey

func (c *Chan) PutKey(k string, v interface{})