fix lint

example/main.go

@@ -42,7 +42,7 @@ func (g *GenInt) Generate(ctx context.Context, input chan<- any) {
 			return
 		default:
 			input <- i
-			i += 1
+			i++
 			time.Sleep(time.Second * 1)
 		}
 	}

pipeline/node/input.go

@@ -120,7 +120,6 @@ func (i *Input) Run(ctx context.Context) error {
 		defer close(input)
 		i.impl.Generate(ctx, input)
 	}()
-
 	return nil
 }
 

pipeline/node/sink.go

@@ -88,7 +88,6 @@ func (s *Sink) GetInputs() []string {
 }
 
 func (s *Sink) Run() error {
-
 	if len(s.inputChannels) == 0 {
 		return errors.New("no input channels configured")
 	}

pipeline/node/transform.go

@@ -113,7 +113,6 @@ func (t *Transform) GetOutputBufferSize() int {
 
 // Run non-blocking call that start Transform node action in separated goroutine.
 func (t *Transform) Run() error {
-
 	if len(t.inputChannels) == 0 {
 		return fmt.Errorf("no input channels configured for '%s'", t.cfg.name)
 	}