Merge pull request #2884 from nspcc-dev/refactor/rpcsrv-error-channel
services/rpcsrv: Strengthen `Server` error channel's type
This commit is contained in:
commit
1262a27065
1 changed files with 2 additions and 2 deletions
|
@ -133,7 +133,7 @@ type (
|
||||||
log *zap.Logger
|
log *zap.Logger
|
||||||
shutdown chan struct{}
|
shutdown chan struct{}
|
||||||
started *atomic.Bool
|
started *atomic.Bool
|
||||||
errChan chan error
|
errChan chan<- error
|
||||||
|
|
||||||
sessionsLock sync.Mutex
|
sessionsLock sync.Mutex
|
||||||
sessions map[string]*session
|
sessions map[string]*session
|
||||||
|
@ -255,7 +255,7 @@ var invalidBlockHeightError = func(index int, height int) *neorpc.Error {
|
||||||
|
|
||||||
// New creates a new Server struct.
|
// New creates a new Server struct.
|
||||||
func New(chain Ledger, conf config.RPC, coreServer *network.Server,
|
func New(chain Ledger, conf config.RPC, coreServer *network.Server,
|
||||||
orc OracleHandler, log *zap.Logger, errChan chan error) Server {
|
orc OracleHandler, log *zap.Logger, errChan chan<- error) Server {
|
||||||
addrs := conf.GetAddresses()
|
addrs := conf.GetAddresses()
|
||||||
httpServers := make([]*http.Server, len(addrs))
|
httpServers := make([]*http.Server, len(addrs))
|
||||||
for i, addr := range addrs {
|
for i, addr := range addrs {
|
||||||
|
|
Loading…
Reference in a new issue