Commit 1d1f0c06 authored by Michael de Hoog's avatar Michael de Hoog

Remove SetLimit for unlimited

parent 8ce2ad39
...@@ -95,7 +95,7 @@ func (q *Queue[T]) TrySend(ctx context.Context, factory TxFactory[T], receiptCh ...@@ -95,7 +95,7 @@ func (q *Queue[T]) TrySend(ctx context.Context, factory TxFactory[T], receiptCh
return false, nil return false, nil
} }
err := <-factoryErrCh err := <-factoryErrCh
return err != nil, err return err == nil, err
} }
func (q *Queue[T]) sendTx(ctx context.Context, factory TxFactory[T], factoryErrorCh chan error, receiptCh chan TxReceipt[T]) error { func (q *Queue[T]) sendTx(ctx context.Context, factory TxFactory[T], factoryErrorCh chan error, receiptCh chan TxReceipt[T]) error {
...@@ -135,8 +135,6 @@ func (q *Queue[T]) mergeWithGroupContext(ctx context.Context) (context.Context, ...@@ -135,8 +135,6 @@ func (q *Queue[T]) mergeWithGroupContext(ctx context.Context) (context.Context,
q.group, q.groupCtx = errgroup.WithContext(context.Background()) q.group, q.groupCtx = errgroup.WithContext(context.Background())
if q.maxPending > 0 { if q.maxPending > 0 {
q.group.SetLimit(int(q.maxPending)) q.group.SetLimit(int(q.maxPending))
} else {
q.group.SetLimit(-1)
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment