diff --git a/zq/zq.go b/zq/zq.go index 3508c6df3b947f5d2eeddb6eefa727584f979564..a0d088d56d95159d9c5a9cbd622639f9daa604b2 100644 --- a/zq/zq.go +++ b/zq/zq.go @@ -126,6 +126,11 @@ func (q *ZQ) AddJobForce(a any) error { return nil } +func (q *ZQ) MustJob(a any) { + q.ZQuit.Inc() + q.Jobs <- a +} + func (q *ZQ) Wait() { q.ZQuit.Wait() }