diff --git a/packages/core/src/core/client.test.ts b/packages/core/src/core/client.test.ts
index 36ceb4758f..5e3f8eb783 100644
--- a/packages/core/src/core/client.test.ts
+++ b/packages/core/src/core/client.test.ts
@@ -50,8 +50,6 @@ vi.mock('./turn', () => {
     GeminiEventType: {
       MaxSessionTurns: 'MaxSessionTurns',
       ChatCompressed: 'ChatCompressed',
-      Error: 'error',
-      Content: 'content',
     },
   };
 });
@@ -1865,89 +1863,6 @@ ${JSON.stringify(
         expect(JSON.stringify(finalCall)).toContain('fileC.ts');
       });
     });
-
-    it('should not call checkNextSpeaker when turn.run() yields an error', async () => {
-      // Arrange
-      const { checkNextSpeaker } = await import(
-        '../utils/nextSpeakerChecker.js'
-      );
-      const mockCheckNextSpeaker = vi.mocked(checkNextSpeaker);
-
-      const mockStream = (async function* () {
-        yield {
-          type: GeminiEventType.Error,
-          value: { error: { message: 'test error' } },
-        };
-      })();
-      mockTurnRunFn.mockReturnValue(mockStream);
-
-      const mockChat: Partial<GeminiChat> = {
-        addHistory: vi.fn(),
-        getHistory: vi.fn().mockReturnValue([]),
-      };
-      client['chat'] = mockChat as GeminiChat;
-
-      const mockGenerator: Partial<ContentGenerator> = {
-        countTokens: vi.fn().mockResolvedValue({ totalTokens: 0 }),
-        generateContent: mockGenerateContentFn,
-      };
-      client['contentGenerator'] = mockGenerator as ContentGenerator;
-
-      // Act
-      const stream = client.sendMessageStream(
-        [{ text: 'Hi' }],
-        new AbortController().signal,
-        'prompt-id-error',
-      );
-      for await (const _ of stream) {
-        // consume stream
-      }
-
-      // Assert
-      expect(mockCheckNextSpeaker).not.toHaveBeenCalled();
-    });
-
-    it('should not call checkNextSpeaker when turn.run() yields a value then an error', async () => {
-      // Arrange
-      const { checkNextSpeaker } = await import(
-        '../utils/nextSpeakerChecker.js'
-      );
-      const mockCheckNextSpeaker = vi.mocked(checkNextSpeaker);
-
-      const mockStream = (async function* () {
-        yield { type: GeminiEventType.Content, value: 'some content' };
-        yield {
-          type: GeminiEventType.Error,
-          value: { error: { message: 'test error' } },
-        };
-      })();
-      mockTurnRunFn.mockReturnValue(mockStream);
-
-      const mockChat: Partial<GeminiChat> = {
-        addHistory: vi.fn(),
-        getHistory: vi.fn().mockReturnValue([]),
-      };
-      client['chat'] = mockChat as GeminiChat;
-
-      const mockGenerator: Partial<ContentGenerator> = {
-        countTokens: vi.fn().mockResolvedValue({ totalTokens: 0 }),
-        generateContent: mockGenerateContentFn,
-      };
-      client['contentGenerator'] = mockGenerator as ContentGenerator;
-
-      // Act
-      const stream = client.sendMessageStream(
-        [{ text: 'Hi' }],
-        new AbortController().signal,
-        'prompt-id-error',
-      );
-      for await (const _ of stream) {
-        // consume stream
-      }
-
-      // Assert
-      expect(mockCheckNextSpeaker).not.toHaveBeenCalled();
-    });
   });
 
   describe('generateContent', () => {
diff --git a/packages/core/src/core/client.ts b/packages/core/src/core/client.ts
index c37cc01a3d..d521ab185b 100644
--- a/packages/core/src/core/client.ts
+++ b/packages/core/src/core/client.ts
@@ -517,9 +517,6 @@ export class GeminiClient {
         return turn;
       }
       yield event;
-      if (event.type === GeminiEventType.Error) {
-        return turn;
-      }
     }
     if (!turn.pendingToolCalls.length && signal && !signal.aborted) {
       // Check if model was switched during the call (likely due to quota error)