Fixed also existing calls to BoardListWatch

Author: cmaglie

internal/cli/arguments/port.go

@@ -89,17 +89,14 @@ func (p *Port) GetPort(ctx context.Context, instance *rpc.Instance, srv rpc.Ardu
 	}
 	logrus.WithField("port", address).Tracef("Upload port")
 
-	ctx, cancel := context.WithCancel(ctx)
+	ctx, cancel := context.WithTimeout(ctx, p.timeout.Get())
 	defer cancel()
 
 	stream, watcher := commands.BoardListWatchProxyToChan(ctx)
-	err := srv.BoardListWatch(&rpc.BoardListWatchRequest{Instance: instance}, stream)
+	go func() {
+		_ = srv.BoardListWatch(&rpc.BoardListWatchRequest{Instance: instance}, stream)
+	}()
 
-	if err != nil {
-		return nil, err
-	}
-
-	deadline := time.After(p.timeout.Get())
 	for {
 		select {
 		case portEvent := <-watcher:
@@ -111,7 +108,7 @@ func (p *Port) GetPort(ctx context.Context, instance *rpc.Instance, srv rpc.Ardu
 				return port, nil
 			}
 
-		case <-deadline:
+		case <-ctx.Done():
 			// No matching port found
 			if protocol == "" {
 				return &rpc.Port{

internal/cli/board/list.go

@@ -91,10 +91,12 @@ func runListCommand(ctx context.Context, srv rpc.ArduinoCoreServiceServer, watch
 
 func watchList(ctx context.Context, inst *rpc.Instance, srv rpc.ArduinoCoreServiceServer) {
 	stream, eventsChan := commands.BoardListWatchProxyToChan(ctx)
-	err := srv.BoardListWatch(&rpc.BoardListWatchRequest{Instance: inst}, stream)
-	if err != nil {
-		feedback.Fatal(i18n.Tr("Error detecting boards: %v", err), feedback.ErrNetwork)
-	}
+	go func() {
+		err := srv.BoardListWatch(&rpc.BoardListWatchRequest{Instance: inst}, stream)
+		if err != nil {
+			feedback.Fatal(i18n.Tr("Error detecting boards: %v", err), feedback.ErrNetwork)
+		}
+	}()
 
 	// This is done to avoid printing the header each time a new event is received
 	if feedback.GetFormat() == feedback.Text {