fix(lifecycle): adapt close channel handling

engine/lifecycle.go

@@ -21,10 +21,12 @@ import (
 )
 
 func (e *QueryEngine) Connect() error {
+	e.closed = make(chan interface{})
+
 	success := false
-	go func() {
+	defer func() {
 		if !success {
-			e.closed <- struct{}{}
+			close(e.closed)
 		}
 	}()
 
@@ -80,7 +82,7 @@ func (e *QueryEngine) Disconnect() error {
 		}
 	}
 
-	e.closed <- struct{}{}
+	close(e.closed)
 
 	logger.Debug.Printf("disconnected.")
 	return nil
@@ -238,7 +240,6 @@ func (e *QueryEngine) spawn(file string) error {
 	e.cmd.Stdout = os.Stdout
 
 	e.onEngineError = make(chan string)
-	e.closed = make(chan interface{})
 
 	if err := e.streamStderr(e.cmd, e.onEngineError); err != nil {
 		return fmt.Errorf("setup stream: %w", err)

engine/stream.go

@@ -6,6 +6,8 @@ import (
 	"fmt"
 	"log"
 	"os/exec"
+
+	"github.com/steebchen/prisma-client-go/logger"
 )
 
 type Messsage struct {
@@ -26,6 +28,7 @@ func (e *QueryEngine) streamStderr(cmd *exec.Cmd, onError chan<- string) error {
 			case v := <-e.onEngineError:
 				e.lastEngineError = v
 			case <-e.closed:
+				logger.Debug.Printf("query engine closed")
 				break outer
 			}
 		}