From 579ae70085c4941ef31ac0dbbd624bf88d4d0829 Mon Sep 17 00:00:00 2001 From: Karim Radhouani Date: Tue, 27 Feb 2024 14:08:40 -0800 Subject: [PATCH] wait for all ONCE subscriptions before returning --- pkg/app/gnmi_client_subscribe.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/app/gnmi_client_subscribe.go b/pkg/app/gnmi_client_subscribe.go index b64261c0..e15b787f 100644 --- a/pkg/app/gnmi_client_subscribe.go +++ b/pkg/app/gnmi_client_subscribe.go @@ -289,7 +289,7 @@ OUTER: switch rsp.Response.(type) { case *gnmi.SubscribeResponse_SyncResponse: a.Logger.Printf("target %q, subscription %q received sync response", t.Config.Name, sreq.name) - return nil + continue default: m := outputs.Meta{"source": t.Config.Name, "format": a.Config.Format, "subscription-name": sreq.name} a.Export(ctx, rsp, m, t.Config.Outputs...)