streaming

Documentation

Index

• func AllDone(in ...<-chan struct{}) <-chan struct{}
• func Apply[T any](done <-chan struct{}, ch <-chan T, fn func(T) T) <-chan T
• func Batch[T any](doneCh <-chan struct{}, inCh <-chan T, batchSize int, timeout time.Duration) <-chan []T
• func Consume[T any](in <-chan T)
• func Copy[T any](out chan<- T, in <-chan T)
• func CopyWG[T any](wg *sync.WaitGroup, out chan<- T, in <-chan T)
• func Demultiplex[T any](done <-chan struct{}, in <-chan T, ch ...chan<- T)
• func Done(in ...<-chan struct{}) <-chan struct{}
• func Error(in <-chan error) error
• func ErrorLog(in <-chan error)
• func FanOut[T any](in <-chan T, num int) []chan T
• func Gather[T any](in <-chan T) []T
• func Generate[T any](done <-chan struct{}, v ...T) <-chan T
• func Loop[T any](done <-chan struct{}, data []T) (<-chan T, error)
• func Merge[T any](in ...<-chan T) <-chan T
• func MergeBuffer[T any](buffer int, in ...<-chan T) <-chan T
• func MergeDone[T any](done <-chan struct{}, ch ...<-chan T) <-chan T
• func MergeError[T any](inCh []<-chan T, errCh []<-chan error) (<-chan T, <-chan error)
• func Morph[I any, O any](done <-chan struct{}, ch <-chan I, fn func(I) (O, error)) <-chan O

Functions

func AllDone

func AllDone(in ...<-chan struct{}) <-chan struct{}

func Apply

func Apply[T any](done <-chan struct{}, ch <-chan T, fn func(T) T) <-chan T

func Batch

func Batch[T any](doneCh <-chan struct{}, inCh <-chan T, batchSize int, timeout time.Duration) <-chan []T

func Consume

func Consume[T any](in <-chan T)

func Copy

func Copy[T any](out chan<- T, in <-chan T)

func CopyWG

func CopyWG[T any](wg *sync.WaitGroup, out chan<- T, in <-chan T)

func Demultiplex

func Demultiplex[T any](done <-chan struct{}, in <-chan T, ch ...chan<- T)

func Done

func Done(in ...<-chan struct{}) <-chan struct{}

Done combine done channels

func Error

func Error(in <-chan error) error

func ErrorLog

func ErrorLog(in <-chan error)

func FanOut

func FanOut[T any](in <-chan T, num int) []chan T

func Gather

func Gather[T any](in <-chan T) []T

func Generate

func Generate[T any](done <-chan struct{}, v ...T) <-chan T

func Loop

func Loop[T any](done <-chan struct{}, data []T) (<-chan T, error)

func Merge

func Merge[T any](in ...<-chan T) <-chan T

func MergeBuffer

func MergeBuffer[T any](buffer int, in ...<-chan T) <-chan T

func MergeDone

func MergeDone[T any](done <-chan struct{}, ch ...<-chan T) <-chan T

func MergeError

func MergeError[T any](inCh []<-chan T, errCh []<-chan error) (<-chan T, <-chan error)

func Morph

func Morph[I any, O any](done <-chan struct{}, ch <-chan I, fn func(I) (O, error)) <-chan O