chain: update neutrino API usage

This commit is contained in:
Olaoluwa Osuntokun 2018-07-13 16:46:45 -07:00
parent 43244ccc61
commit 64b5b448f5

View file

@ -385,7 +385,7 @@ func (s *NeutrinoClient) Rescan(startHash *chainhash.Hash, addrs []btcutil.Addre
neutrino.WatchAddrs(addrs...), neutrino.WatchAddrs(addrs...),
neutrino.WatchOutPoints(watchOutPoints...), neutrino.WatchOutPoints(watchOutPoints...),
) )
s.rescan = &newRescan s.rescan = newRescan
s.rescanErr = s.rescan.Start() s.rescanErr = s.rescan.Start()
return nil return nil
@ -433,7 +433,7 @@ func (s *NeutrinoClient) NotifyReceived(addrs []btcutil.Address) error {
neutrino.QuitChan(s.rescanQuit), neutrino.QuitChan(s.rescanQuit),
neutrino.WatchAddrs(addrs...), neutrino.WatchAddrs(addrs...),
) )
s.rescan = &newRescan s.rescan = newRescan
s.rescanErr = s.rescan.Start() s.rescanErr = s.rescan.Start()
s.clientMtx.Unlock() s.clientMtx.Unlock()
return nil return nil