xstream

Documentation

Index

• func Delayed(delay time.Duration, events <-chan event.Event) <-chan event.Event
• func DelayedFunc(fn func(prev event.Event) time.Duration, events <-chan event.Event) <-chan event.Event

Functions

func Delayed

func Delayed(delay time.Duration, events <-chan event.Event) <-chan event.Event

Delayed returns a Stream s that adds an artificial delay to calls to s.Next.

func DelayedFunc

func DelayedFunc(fn func(prev event.Event) time.Duration, events <-chan event.Event) <-chan event.Event

DelayedFunc returns a Stream s that adds an artificial delay to calls to s.Next.