Method wait

pkg/podlogs/cluster_writer.go:166–168

wait blocks until there are no active processes

()

// wait blocks until there are no active processes
func (as *activeSet) wait() {
	as.wg.Wait()
}

// SingleStream streams the cluster's pod logs and shunts them to a single io.Writer
func (csr *ClusterWriter) SingleStream(ctx context.Context, writer io.Writer) error {