diff --git a/packages/api/gateway/src/client/journal-stream.ts b/packages/api/gateway/src/client/journal-stream.ts
index ab013abdf3..35dcb86255 100644
--- a/packages/api/gateway/src/client/journal-stream.ts
+++ b/packages/api/gateway/src/client/journal-stream.ts
@@ -241,6 +241,10 @@ export abstract class RemoteJournalStream<
         if (next.done) return
         const item = next.value
         if (item.generation !== this.generation) {
+          // A replaced carrier can surface buffered live entries before its
+          // opening snapshot. The snapshot subsumes them, so retain the
+          // published window and wait for that generation's opening cursor.
+          if (item.value.type !== 'opened') continue
           this.replaceGeneration(item, true)
           continue
         }
diff --git a/packages/api/gateway/tests/journal-stream.client.spec.ts b/packages/api/gateway/tests/journal-stream.client.spec.ts
index 498f5a033b..e6f1b41f69 100644
--- a/packages/api/gateway/tests/journal-stream.client.spec.ts
+++ b/packages/api/gateway/tests/journal-stream.client.spec.ts
@@ -788,7 +788,7 @@ describe('RemoteJournalStream', () => {
     await fixture.journal.dispose()
   })
 
-  it('reports a resumed generation that emits an entry before its cursor', async () => {
+  it('drops resumed entries before the replacement opening cursor', async () => {
     const finish = Promise.withResolvers<undefined>()
     const fixture = journalFixture(
       [
@@ -797,13 +797,46 @@ describe('RemoteJournalStream', () => {
           waitAfterFrames: finish.promise,
           terminal: new RemoteStreamCarrierError('lost'),
         },
-        { frames: [{ type: 'entry', entry: { seq: 1 } }] },
+        {
+          frames: [
+            { type: 'entry', entry: { seq: 1 } },
+            opened(1, page('replacement', [0, 1])),
+          ],
+          hold: true,
+        },
       ],
       [],
     )
 
     await fixture.journal.open({})
     finish.resolve(undefined)
+    await vi.waitFor(() => { expect(fixture.changes).toHaveLength(2) })
+    expect(fixture.changes.at(-1)).toMatchObject({
+      type: 'replace',
+      page: { marker: 'replacement' },
+      entries: [{ seq: 0 }, { seq: 1 }],
+    })
+    expect(fixture.failed).not.toHaveBeenCalled()
+    await fixture.journal.dispose()
+  })
+
+  it('rejects a superseded repair whose replacement emits an entry first', async () => {
+    const gap = Promise.withResolvers<ScriptedFrame>()
+    const fixture = journalFixture(
+      [
+        {
+          frames: [opened(1, page('initial', [0, 1])), gap.promise],
+          terminal: new RemoteStreamCarrierError('generation lost'),
+        },
+        { frames: [{ type: 'entry', entry: { seq: 4 } }], hold: true },
+      ],
+      [
+        () => new Promise<Page>(() => {}),
+      ],
+    )
+
+    await fixture.journal.open({ limit: 5 })
+    gap.resolve({ type: 'entry', entry: { seq: 4 } })
     await vi.waitFor(() => { expect(fixture.failed).toHaveBeenCalledOnce() })
     expect(fixture.failed.mock.calls[0]?.[0]).toMatchObject({
       message: 'resumed fixture journal emitted an entry before its opening cursor',