summaryrefslogtreecommitdiff
path: root/plugins
diff options
context:
space:
mode:
authorWolfy-J <[email protected]>2020-10-25 16:19:14 +0300
committerWolfy-J <[email protected]>2020-10-25 16:19:14 +0300
commit7d01ccafa5fe698a776aceb1511294283cededec (patch)
treeb8ca1eddb2c8c82137297aee02b4d629678cd8e0 /plugins
parentba5c562f9038ba434e655fb82c44597fcccaff16 (diff)
- massive update in roadrunner 2.0 abstractions
Diffstat (limited to 'plugins')
-rw-r--r--plugins/rpc/rpc.go5
1 files changed, 2 insertions, 3 deletions
diff --git a/plugins/rpc/rpc.go b/plugins/rpc/rpc.go
index 7b47682f..294eeb7a 100644
--- a/plugins/rpc/rpc.go
+++ b/plugins/rpc/rpc.go
@@ -4,7 +4,6 @@ import (
"github.com/spiral/endure/errors"
"github.com/spiral/goridge/v2"
"github.com/spiral/roadrunner/v2/plugins/config"
-
"net/rpc"
)
@@ -50,7 +49,7 @@ func (s *Service) Init(cfg config.Provider) error {
// Serve serves the service.
func (s *Service) Serve() chan error {
- s.close = make(chan struct{})
+ s.close = make(chan struct{}, 1)
errCh := make(chan error, 1)
s.rpc = rpc.NewServer()
@@ -88,7 +87,7 @@ func (s *Service) Serve() chan error {
}
}()
- return nil
+ return errCh
}
// Stop stops the service.