@@ -28,7 +28,7 @@ type SweepingProvider struct {
2828// New creates a new SweepingProvider that manages provides and reprovides for
2929// both DHT swarms (LAN and WAN) in a dual DHT setup.
3030func New (d * dual.DHT , opts ... Option ) (* SweepingProvider , error ) {
31- if d == nil || ( d .LAN == nil || d .WAN == nil ) {
31+ if d == nil || d .LAN == nil || d .WAN == nil {
3232 return nil , errors .New ("cannot create sweeping provider for nil dual DHT" )
3333 }
3434
@@ -84,21 +84,20 @@ func New(d *dual.DHT, opts ...Option) (*SweepingProvider, error) {
8484// runOnBoth runs the provided function on both the LAN and WAN providers in
8585// parallel and waits for both to complete.
8686func (s * SweepingProvider ) runOnBoth (f func (* provider.SweepingProvider ) error ) error {
87- var errs [2 ]error
88- done := make (chan struct {})
87+ errCh := make (chan error , 1 )
8988 go func () {
90- defer close (done )
9189 err := f (s .LAN )
9290 if err != nil {
93- errs [ 0 ] = fmt .Errorf ("LAN provider: %w" , err )
91+ err = fmt .Errorf ("LAN provider: %w" , err )
9492 }
93+ errCh <- err
9594 }()
9695 err := f (s .WAN )
9796 if err != nil {
98- errs [ 1 ] = fmt .Errorf ("WAN provider: %w" , err )
97+ err = fmt .Errorf ("WAN provider: %w" , err )
9998 }
100- <- done
101- return errors .Join (errs [:] ... )
99+ lanErr := <- errCh
100+ return errors .Join (lanErr , err )
102101}
103102
104103// Close stops both DHT providers and releases associated resources.
0 commit comments