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