diff --git a/vocata-server/src/main/java/com/vocata/ai/pipeline/StreamingPipelineOrchestrator.java b/vocata-server/src/main/java/com/vocata/ai/pipeline/StreamingPipelineOrchestrator.java
index 118c14b..68176c7 100644
--- a/vocata-server/src/main/java/com/vocata/ai/pipeline/StreamingPipelineOrchestrator.java
+++ b/vocata-server/src/main/java/com/vocata/ai/pipeline/StreamingPipelineOrchestrator.java
@@ -159,9 +159,10 @@ public Flux<PipelineEvent> processVoiceMessage(String conversationUuid,
 
                     return Flux.concat(
                             Flux.just(new PipelineEvent.StateChange(PipelineState.LISTENING)),
-                            sttEvents.takeUntil(r -> ((PipelineEvent.SttResult) r).isFinal()),
-                            Flux.just(new PipelineEvent.StateChange(PipelineState.PROCESSING)),
-                            llmTtsEvents,
+                            Flux.merge(
+                                    sttEvents.takeUntil(r -> ((PipelineEvent.SttResult) r).isFinal()),
+                                    llmTtsEvents
+                            ),
                             Flux.just(new PipelineEvent.Complete())
                     );
                 })