Added Continue bool to track whether the execution should be terminated

2024-09-12 23:52:35 +03:00 · 2024-09-12 23:52:35 +03:00 · 762f90adf6
commit 762f90adf6
parent 5e4e6a21a0
2 changed files with 2 additions and 1 deletions
--- a/internal/handlers/base.go
+++ b/internal/handlers/base.go
@ -78,7 +78,7 @@ func(f *BaseSessionHandler) Process(rqs RequestSession) (RequestSession, error)
 		return rqs, err
 	}

-	_ = r
+	rqs.Continue = r 
 	return rqs, nil
 }

--- a/internal/handlers/single.go
+++ b/internal/handlers/single.go
@ -34,6 +34,7 @@ type RequestSession struct {
 	Input []byte
 	Storage storage.Storage
 	Writer io.Writer
+	Continue bool
 }

 type engineMaker func(cfg engine.Config, rs resource.Resource, pr *persist.Persister) engine.Engine