diff --git a/emitter.go b/emitter.go index 73000d9..00efb32 100644 --- a/emitter.go +++ b/emitter.go @@ -52,6 +52,7 @@ func Start(plugins *InOutPlugins, stop chan int) { } } +// Close closes all the goroutine and waits for it to finish. func Close(quit chan int) { closeOnce.Do(func() { close(quit)