add MustJob

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()
 }