refactor: move FanoutEmitter to _events module with other emitter implementations

FanoutEmitter is event infrastructure, not manager-specific logic. Grouping
it with EventEmitter, NullEmitter, and QueueEmitter in _events.py improves
module cohesion and makes it available without depending on the UI layer.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: 2 people

agent_docs/CODEBASE_MAP.md

@@ -98,6 +98,7 @@ The run loop communicates via structured events (`_events.py`). Each event has a
 - **`EventEmitter`** — protocol that any listener implements (just an `emit(event)` method)
 - **`NullEmitter`** — discards events (used in tests)
 - **`QueueEmitter`** — pushes events into a `queue.Queue` for async consumption (used by the UI)
+- **`FanoutEmitter`** — broadcasts events to multiple emitters (used by the manager for fan-out to queue + persistence)
 
 The CLI uses a `ConsoleEmitter` (defined in `_console_emitter.py`) that renders events to the terminal with Rich formatting.
 
@@ -107,7 +108,7 @@ The CLI uses a `ConsoleEmitter` (defined in `_console_emitter.py`) that renders
 - Creates runs with unique IDs and wraps them in `ManagedRun` (config + state + emitter + thread)
 - Starts each run in a daemon thread via `engine.run_loop()`
 - Supports pause/resume/stop per run via `RunState` thread-safe control methods
-- Uses `_FanoutEmitter` to broadcast events to multiple listeners (e.g., queue + persistence)
+- Uses `FanoutEmitter` to broadcast events to multiple listeners (e.g., queue + persistence)
 
 ## Key files to understand first
 

src/ralphify/_events.py

@@ -77,3 +77,14 @@ def __init__(self, q: queue.Queue[Event] | None = None) -> None:
 
     def emit(self, event: Event) -> None:
         self.queue.put(event)
+
+
+class FanoutEmitter:
+    """Broadcasts events to multiple emitters."""
+
+    def __init__(self, emitters: list[EventEmitter]) -> None:
+        self._emitters = emitters
+
+    def emit(self, event: Event) -> None:
+        for e in self._emitters:
+            e.emit(event)

src/ralphify/manager.py

@@ -9,7 +9,7 @@
 import uuid
 from dataclasses import dataclass, field
 
-from ralphify._events import Event, EventEmitter, QueueEmitter
+from ralphify._events import EventEmitter, FanoutEmitter, QueueEmitter
 from ralphify.engine import RunConfig, RunState, run_loop
 
 
@@ -28,17 +28,6 @@ def add_listener(self, emitter: EventEmitter) -> None:
         self._extra_emitters.append(emitter)
 
 
-class _FanoutEmitter:
-    """Emits to multiple emitters."""
-
-    def __init__(self, emitters: list[EventEmitter]) -> None:
-        self._emitters = emitters
-
-    def emit(self, event: Event) -> None:
-        for e in self._emitters:
-            e.emit(event)
-
-
 class RunManager:
     """Registry of runs. Thread-safe."""
 
@@ -73,7 +62,7 @@ def start_run(self, run_id: str) -> None:
         """
         managed = self._get_run(run_id)
         all_emitters: list[EventEmitter] = [managed.emitter] + managed._extra_emitters
-        fanout = _FanoutEmitter(all_emitters)
+        fanout = FanoutEmitter(all_emitters)
         thread = threading.Thread(
             target=run_loop,
             args=(managed.config, managed.state, fanout),

tests/test_manager.py

@@ -6,9 +6,9 @@
 from dataclasses import replace
 from unittest.mock import patch
 
-from ralphify._events import Event, EventType, QueueEmitter
+from ralphify._events import Event, EventType, FanoutEmitter, QueueEmitter
 from ralphify.engine import RunConfig, RunStatus
-from ralphify.manager import ManagedRun, RunManager, _FanoutEmitter
+from ralphify.manager import ManagedRun, RunManager
 
 _MOCK_SUBPROCESS = "ralphify.engine.subprocess.run"
 
@@ -213,7 +213,7 @@ class TestFanoutEmitter:
     def test_fanout_emits_to_all(self):
         q1 = QueueEmitter()
         q2 = QueueEmitter()
-        fanout = _FanoutEmitter([q1, q2])
+        fanout = FanoutEmitter([q1, q2])
 
         event = Event(type=EventType.LOG_MESSAGE, run_id="test", data={"msg": "hi"})
         fanout.emit(event)