internal/serial/seriallink.go

@@ -71,7 +71,7 @@ func (h *Handler) Run(ctx context.Context) error {
 
 	defer func() {
 		cancel()
-		h.logger.Info("context canceled, waiting for shutdown of components")
+		h.logger.Info("context canceled waiting for shutdown of components")
 		wg.Wait()
 		h.logger.Info("shutdown complete")
 	}()

pkg/protocol/protocol.go

@@ -510,34 +510,12 @@ func (c *COBSFramer) WriteFrames(ctx context.Context, writer io.Writer, frameCha
 
 			encoded := c.encoder.Encode(frame)
 
-			err := c.writeRaw(ctx, writer, encoded)
+			n, err := io.Copy(writer, bytes.NewReader(encoded))
 			if err != nil {
-				return err
+				return fmt.Errorf("cold not write data: %w", err)
-			}
-		}
-	}
 			}
 
-func (c *COBSFramer) writeRaw(ctx context.Context, writer io.Writer, raw []byte) error {
+			c.logger.Tracef("wrote %d bytes", n)
-	errChan := make(chan error)
+		}
-
-	go func() {
-		n, err := io.Copy(writer, bytes.NewReader(raw))
-		if err != nil {
-			errChan <- fmt.Errorf("could not write data: %w", err)
-
-			return
-		}
-
-		c.logger.WithField("count", n).Tracef("wrote bytes")
-
-		close(errChan)
-	}()
-
-	select {
-	case <-ctx.Done():
-		return nil
-	case err := <-errChan:
-		return err
 	}
 }