diff --git a/lnrpc/routerrpc/router_server.go b/lnrpc/routerrpc/router_server.go index 2d48e675b..595eb1ea0 100644 --- a/lnrpc/routerrpc/router_server.go +++ b/lnrpc/routerrpc/router_server.go @@ -941,10 +941,13 @@ func (s *Server) trackPaymentStream(context context.Context, result := item.(*channeldb.MPPayment) // Skip in-flight updates unless requested. - if noInflightUpdates && - result.Status == channeldb.StatusInFlight { - - continue + if noInflightUpdates { + if result.Status == channeldb.StatusInitiated { + continue + } + if result.Status == channeldb.StatusInFlight { + continue + } } rpcPayment, err := s.cfg.RouterBackend.MarshallPayment(