-package main
+// Copyright (C) The Lightning Authors. All rights reserved.
+//
+// SPDX-License-Identifier: AGPL-3.0
+
+package lightning
import (
"sync"
t.wg.Wait()
return t.Err()
}
+
+func (t *throttle) Go(f func() error) error {
+ t.Acquire()
+ if t.Err() != nil {
+ return t.Err()
+ }
+ go func() {
+ t.Report(f())
+ t.Release()
+ }()
+ return nil
+}