|
|
@ -374,7 +374,7 @@ func (s *lwdStreamer) GetMempoolStream(_empty *walletrpc.Empty, resp walletrpc.C |
|
|
|
var mempoolMap *map[string]*walletrpc.CompactTx |
|
|
|
var mempoolList []string |
|
|
|
|
|
|
|
// Last time we pulled a copy of the mempool from zcashd.
|
|
|
|
// Last time we pulled a copy of the mempool from hushd
|
|
|
|
var lastMempool time.Time |
|
|
|
|
|
|
|
func (s *lwdStreamer) GetMempoolTx(exclude *walletrpc.Exclude, resp walletrpc.CompactTxStreamer_GetMempoolTxServer) error { |
|
|
@ -419,7 +419,7 @@ func (s *lwdStreamer) GetMempoolTx(exclude *walletrpc.Exclude, resp walletrpc.Co |
|
|
|
return err |
|
|
|
} |
|
|
|
|
|
|
|
// conver to binary
|
|
|
|
// convert to binary
|
|
|
|
txBytes, err := hex.DecodeString(txStr) |
|
|
|
if err != nil { |
|
|
|
return err |
|
|
|