diff --git a/rpcserver.go b/rpcserver.go index 9c6d182f..5966daf5 100644 --- a/rpcserver.go +++ b/rpcserver.go @@ -5015,6 +5015,7 @@ func (r *rpcServer) SubscribeTransactions(req *lnrpc.GetTransactionsRequest, return err } defer txClient.Cancel() + rpcsLog.Infof("New transaction subscription") for { select { @@ -5056,6 +5057,7 @@ func (r *rpcServer) SubscribeTransactions(req *lnrpc.GetTransactionsRequest, } case <-updateStream.Context().Done(): + rpcsLog.Infof("Cancelling transaction subscription") return updateStream.Context().Err() case <-r.quit: