delay

Documentation

Index

• func Put(c chan interface{}, v interface{}) bool
• func TryClear(c <-chan interface{})
• func TryMove(in <-chan interface{}, out chan<- interface{}) (bool, interface{})
• func TryPut(c chan<- interface{}, v interface{}) bool
• type Config
  • func New(duration time.Duration, ch chan<- interface{}, callback func(interface{})) *Config
  • func (c *Config) Put(v interface{}, force bool)
  • func (c *Config) Stop()

Functions

func Put

func Put(c chan interface{}, v interface{}) bool

func TryClear

func TryClear(c <-chan interface{})

func TryMove

func TryMove(in <-chan interface{}, out chan<- interface{}) (bool, interface{})

func TryPut

func TryPut(c chan<- interface{}, v interface{}) bool

Types

type Config

type Config struct {
	CacheC   chan interface{}
	OutC     chan<- interface{}
	TickC    chan interface{}
	StopC    chan interface{}
	Callback func(interface{})
}

func New

func New(duration time.Duration, ch chan<- interface{}, callback func(interface{})) *Config

func (*Config) Put

func (c *Config) Put(v interface{}, force bool)

func (*Config) Stop

func (c *Config) Stop()