diff options
author | Wolfy-J <[email protected]> | 2020-10-25 16:19:14 +0300 |
---|---|---|
committer | Wolfy-J <[email protected]> | 2020-10-25 16:19:14 +0300 |
commit | 7d01ccafa5fe698a776aceb1511294283cededec (patch) | |
tree | b8ca1eddb2c8c82137297aee02b4d629678cd8e0 /plugins | |
parent | ba5c562f9038ba434e655fb82c44597fcccaff16 (diff) |
- massive update in roadrunner 2.0 abstractions
Diffstat (limited to 'plugins')
-rw-r--r-- | plugins/rpc/rpc.go | 5 |
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. |