util

Jun 9, 2023

Changes in this version

+ func Shuffle(ctx context.Context, in chan T, targetDistance int) <-chan T

+ type SzError struct

+ Inner error

+ Message string

+ Misc map[string]any

+ StackTrace string

+ func WrapError(err error, messagef string, msgArgs ...any) SzError

+ func (err SzError) Error() string

Feb 14, 2023

Changes in this version

+ func Bridge(ctx context.Context, chanStream <-chan <-chan T) <-chan T

+ func FanIn(ctx context.Context, streams ...<-chan T) <-chan T

+ func Or(channels ...<-chan T) <-chan T

+ func Repeat(ctx context.Context, values ...T) <-chan T

+ func RepeatFn(ctx context.Context, fn func() T) <-chan T

+ func Take(ctx context.Context, valueStream <-chan T, num int) <-chan T

+ func Tee(ctx context.Context, in <-chan T) (_, _ <-chan T)

Feb 10, 2023

Changes in this version

+ func OrDone(ctx context.Context, c <-chan T) <-chan T