Queue device commands and replay first results

[onehouse] / driver / runner.go

diff --git a/driver/runner.go b/driver/runner.go
index e918416a7a4e02b585c84c3c82fade7b9ad8a00b..b40702bb0267331083e57789fbecf4cf4e13b8ab 100644 (file)
--- a/driver/runner.go
+++ b/driver/runner.go
@@ -31,7 +31,10 @@ func Run(ctx context.Context, drivers []Driver, connected <-chan struct{}) error
 
        for index, integration := range drivers {
                workers.Go(func() {
-                       results <- driverResult{index: index, err: integration.Run(ctx)}
+                       results <- driverResult{
+                               index: index,
+                               err:   integration.Run(ctx),
+                       }
                })
        }
 
@@ -68,11 +71,6 @@ func Run(ctx context.Context, drivers []Driver, connected <-chan struct{}) error
        return errors.Join(failures...)
 }
 
-type driverResult struct {
-       index int
-       err   error
-}
-
 func stopOnly(err error, cancellation error) bool {
        joined, ok := err.(interface{ Unwrap() []error })
        if ok {