utils

Documentation

Index

• func RunConcurrentlyUntil(stopCh <-chan struct{}, funcs ...StoppableFunc)
• type StoppableFunc

Functions

func RunConcurrentlyUntil

func RunConcurrentlyUntil(stopCh <-chan struct{}, funcs ...StoppableFunc)

RunConcurrentlyUntil runs several stoppable functions in parallel and blocks until all of them are executed.

Types

type StoppableFunc

type StoppableFunc func(<-chan struct{})

StoppableFunc is a type of function that blocks on run, but can be stopped via stop channel passed as an argument