From a11c6d00110bc3eb19edd7e2b906683a734d8caf Mon Sep 17 00:00:00 2001 From: brharrington Date: Mon, 12 Aug 2024 15:53:09 -0500 Subject: [PATCH] lwcapi: fix push for new subs (#1684) If subs change after the data source has been pushed, then it wouldn't push the high priority messages until the next pull. Now it will go ahead and push if messages are ready. --- .../com/netflix/atlas/lwcapi/WebSocketSessionManager.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/atlas-lwcapi/src/main/scala/com/netflix/atlas/lwcapi/WebSocketSessionManager.scala b/atlas-lwcapi/src/main/scala/com/netflix/atlas/lwcapi/WebSocketSessionManager.scala index 7fcd4cc1b..8b91d991b 100644 --- a/atlas-lwcapi/src/main/scala/com/netflix/atlas/lwcapi/WebSocketSessionManager.scala +++ b/atlas-lwcapi/src/main/scala/com/netflix/atlas/lwcapi/WebSocketSessionManager.scala @@ -89,7 +89,7 @@ private[lwcapi] class WebSocketSessionManager( } else { // Only pull when no push happened, because push should have triggered a pull // from downstream - pull(in) + onPull() } } }