diff --git a/atlas-lwcapi/src/main/scala/com/netflix/atlas/lwcapi/SubscribeApi.scala b/atlas-lwcapi/src/main/scala/com/netflix/atlas/lwcapi/SubscribeApi.scala
index 349fde1b6..2d2f92457 100644
--- a/atlas-lwcapi/src/main/scala/com/netflix/atlas/lwcapi/SubscribeApi.scala
+++ b/atlas-lwcapi/src/main/scala/com/netflix/atlas/lwcapi/SubscribeApi.scala
@@ -195,11 +195,12 @@ class SubscribeApi(
 
         // Add any new expressions
         val (queue, addedSubs) = sm.subscribe(streamId, splits)
-        addedSubs.foreach { sub =>
+        val subMessages = addedSubs.map { sub =>
           val meta = sub.metadata
           val exprInfo = LwcDataExpr(meta.id, meta.expression, meta.frequency)
-          queue.offer(Seq(LwcSubscription(expr.expression, List(exprInfo))))
+          LwcSubscription(expr.expression, List(exprInfo))
         }
+        queue.offer(subMessages)
 
         // Add expression ids in use by this split
         subIdsBuilder ++= splits.map(_.metadata.id)