diff --git a/zq/zq.go b/zq/zq.go index 477bf903fd08c90287c6a2fc14bcf61bcf0caee8..e22be79c6ab1560f24ea072aee03c349f8073081 100644 --- a/zq/zq.go +++ b/zq/zq.go @@ -72,6 +72,13 @@ func (q *ZQ) AddJob(a any) *ZQ { return q } +func (q *ZQ) AddJobSync(a any) *ZQ { + q.JobsWg.Inc() + q.jobs <- a + + return q +} + func (q *ZQ) Wait() { q.JobsWg.Wait() }