flow

Documentation

Index

• func AwaitExp(delay time.Duration) (delays []time.Duration)
• func Retry(ctx context.Context, duration time.Duration, ...) (err error)
• func RetryT[T any](ctx context.Context, duration time.Duration, ...) (t T, err error)
• type Input
  • func From[T any](in <-chan T) Input[T]
  • func Map[T1 any, T2 any](from <-chan T1, transform func(T1) (T2, bool)) (to Input[T2])
  • func (f Input[T]) Debounce(t time.Duration) (input Input[T])

Functions

func AwaitExp

func AwaitExp(delay time.Duration) (delays []time.Duration)

func Retry

func Retry(
	ctx context.Context,
	duration time.Duration,
	retry func(i int, n int, d time.Duration) (err error),
) (err error)

func RetryT

func RetryT[T any](
	ctx context.Context,
	duration time.Duration,
	retry func(i int, n int, d time.Duration) (t T, err error),
) (t T, err error)

Types

type Input

type Input[T any] <-chan T

func From

func From[T any](in <-chan T) Input[T]

func Map

func Map[T1 any, T2 any](from <-chan T1, transform func(T1) (T2, bool)) (to Input[T2])

func (Input[T]) Debounce

func (f Input[T]) Debounce(t time.Duration) (input Input[T])