reverted changes to response

anthdm · Aug 19, 2024 · 069c336 · 069c336
1 parent 26b191f
commit 069c336
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 9 deletions.
diff --git a/actor/engine.go b/actor/engine.go
@@ -111,10 +111,7 @@ func (e *Engine) Address() string {
 // block until the deadline is exceeded or the response is being resolved.
 func (e *Engine) Request(pid *PID, msg any, timeout time.Duration) *Response {
 	resp := NewResponse(e, timeout)
-	if err := e.Registry.add(resp); err != nil {
-		resp.err = err
-		return resp
-	}
+	e.Registry.add(resp)
 
 	e.SendWithSender(pid, msg, resp.PID())
 

diff --git a/actor/response.go b/actor/response.go
@@ -14,7 +14,6 @@ type Response struct {
 	pid     *PID
 	result  chan any
 	timeout time.Duration
-	err     error
 }
 
 func NewResponse(e *Engine, timeout time.Duration) *Response {
@@ -33,10 +32,6 @@ func (r *Response) Result() (any, error) {
 		r.engine.Registry.Remove(r.pid)
 	}()
 
-	if r.err != nil {
-		return nil, r.err
-	}
-
 	select {
 	case resp := <-r.result:
 		return resp, nil