pipe

Documentation

Index

• func Emit[T any](eg chan<- T, frequency time.Duration, f func() (T, error))
• func ForEach[A any](in <-chan A, f func(A))

Functions

func Emit

func Emit[T any](eg chan<- T, frequency time.Duration, f func() (T, error))

Emit periodically message from the function

func ForEach

func ForEach[A any](in <-chan A, f func(A))

ForEach applies function for each message in the channel