xstream

Documentation

Index

• func Delayed[D any](delay time.Duration, events <-chan event.Of[D]) <-chan event.Of[D]
• func DelayedFunc[D any](fn func(prev event.Of[D]) time.Duration, events <-chan event.Of[D]) <-chan event.Of[D]

Functions

func Delayed

func Delayed[D any](delay time.Duration, events <-chan event.Of[D]) <-chan event.Of[D]

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

func DelayedFunc

func DelayedFunc[D any](fn func(prev event.Of[D]) time.Duration, events <-chan event.Of[D]) <-chan event.Of[D]

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