diff options
author | Wolfy-J <[email protected]> | 2018-06-06 16:01:06 +0300 |
---|---|---|
committer | Wolfy-J <[email protected]> | 2018-06-06 16:01:06 +0300 |
commit | c0abdf657a0a5de02b63683a60bf13b88895ef79 (patch) | |
tree | b497e98a7c2cf73f7a8377de7566a3f7b4b72a5e /server.go | |
parent | e863c6cdcf7c318fb251e096bf92812ed98ea03c (diff) |
better server re-configuration
Diffstat (limited to 'server.go')
-rw-r--r-- | server.go | 12 |
1 files changed, 5 insertions, 7 deletions
@@ -46,8 +46,11 @@ type Server struct { } // NewServer creates new router. Make sure to call configure before the usage. -func NewServer(cfg *ServerConfig) *Server { - return &Server{cfg: cfg} +func NewServer(cfg *ServerConfig, o func(event int, ctx interface{})) *Server { + return &Server{ + cfg: cfg, + observer: o, + } } // Reconfigure re-configures underlying pool and destroys it's previous version if any. @@ -94,11 +97,6 @@ func (srv *Server) Reset() error { return srv.Reconfigure(srv.cfg) } -// Observe attaches event watcher to the router. -func (srv *Server) Observe(o func(event int, ctx interface{})) { - srv.observer = o -} - // Start underlying worker pool, configure factory and command provider. func (srv *Server) Start() (err error) { srv.mu.Lock() |