refactor: rename to bidi input and output events

Author: Murat Kaan Meral

src/strands/experimental/bidirectional_streaming/__init__.py

@@ -22,11 +22,11 @@
     BidiConnectionStartEvent,
     BidiErrorEvent,
     BidiImageInputEvent,
-    InputEvent,
+    BidiInputEvent,
     BidiInterruptionEvent,
     ModalityUsage,
     BidiUsageEvent,
-    OutputEvent,
+    BidiOutputEvent,
     BidiResponseCompleteEvent,
     BidiResponseStartEvent,
     BidiTextInputEvent,
@@ -54,7 +54,7 @@
     "BidiTextInputEvent",
     "BidiAudioInputEvent",
     "BidiImageInputEvent",
-    "InputEvent",
+    "BidiInputEvent",
 
     # Output Event types
     "BidiConnectionStartEvent",
@@ -67,7 +67,7 @@
     "BidiUsageEvent",
     "ModalityUsage",
     "BidiErrorEvent",
-    "OutputEvent",
+    "BidiOutputEvent",
 
     # Tool Event types (reused from standard agent)
     "ToolUseStreamEvent",

src/strands/experimental/bidirectional_streaming/agent/agent.py

@@ -34,7 +34,7 @@
 )
 from ..models.bidirectional_model import BidiModel
 from ..models.novasonic import BidiNovaSonicModel
-from ..types.events import BidiAudioInputEvent, BidiImageInputEvent, BidiTextInputEvent, InputEvent, OutputEvent
+from ..types.events import BidiAudioInputEvent, BidiImageInputEvent, BidiTextInputEvent, BidiInputEvent, BidiOutputEvent
 from ..types import BidiIO
 from ....experimental.tools import ToolProvider
 
@@ -325,10 +325,10 @@ async def send(self, input_data: BidirectionalInput) -> None:
 
         # If we get here, input type is invalid
         raise ValueError(
-            f"Input must be a string, InputEvent (BidiTextInputEvent/BidiAudioInputEvent/BidiImageInputEvent), or event dict with 'type' field, got: {type(input_data)}"
+            f"Input must be a string, BidiInputEvent (BidiTextInputEvent/BidiAudioInputEvent/BidiImageInputEvent), or event dict with 'type' field, got: {type(input_data)}"
         )
 
-    async def receive(self) -> AsyncIterable[OutputEvent]:
+    async def receive(self) -> AsyncIterable[BidiOutputEvent]:
         """Receive events from the model including audio, text, and tool calls.
 
         Yields model output events processed by background tasks including audio output,

src/strands/experimental/bidirectional_streaming/models/bidirectional_model.py

@@ -21,8 +21,8 @@
 from ..types.events import (
     BidiAudioInputEvent,
     BidiImageInputEvent,
-    InputEvent,
-    OutputEvent,
+    BidiInputEvent,
+    BidiOutputEvent,
     BidiTextInputEvent,
 )
 
@@ -67,7 +67,7 @@ async def stop(self) -> None:
         """
         ...
 
-    async def receive(self) -> AsyncIterable[OutputEvent]:
+    async def receive(self) -> AsyncIterable[BidiOutputEvent]:
         """Receive streaming events from the model.
 
         Continuously yields events from the model as they arrive over the connection.
@@ -77,14 +77,14 @@ async def receive(self) -> AsyncIterable[OutputEvent]:
         The stream continues until the connection is closed or an error occurs.
 
         Yields:
-            OutputEvent: Standardized event objects containing audio output,
+            BidiOutputEvent: Standardized event objects containing audio output,
                 transcripts, tool calls, or control signals.
         """
         ...
 
     async def send(
         self,
-        content: InputEvent | ToolResultEvent,
+        content: BidiInputEvent | ToolResultEvent,
     ) -> None:
         """Send content to the model over the active connection.
 

src/strands/experimental/bidirectional_streaming/models/gemini_live.py

@@ -31,7 +31,7 @@
     BidiConnectionStartEvent,
     BidiErrorEvent,
     BidiImageInputEvent,
-    InputEvent,
+    BidiInputEvent,
     BidiInterruptionEvent,
     BidiUsageEvent,
     BidiTextInputEvent,
@@ -334,7 +334,7 @@ def _convert_gemini_live_event(self, message: LiveServerMessage) -> Optional[Dic
 
     async def send(
         self,
-        content: InputEvent | ToolResultEvent,
+        content: BidiInputEvent | ToolResultEvent,
     ) -> None:
         """Unified send method for all content types. Sends the given inputs to Google Live API
         

src/strands/experimental/bidirectional_streaming/models/novasonic.py

@@ -40,10 +40,10 @@
     BidiConnectionStartEvent,
     BidiErrorEvent,
     BidiImageInputEvent,
-    InputEvent,
+    BidiInputEvent,
     BidiInterruptionEvent,
     BidiUsageEvent,
-    OutputEvent,
+    BidiOutputEvent,
     BidiTextInputEvent,
     BidiTranscriptStreamEvent,
     BidiResponseCompleteEvent,
@@ -308,7 +308,7 @@ async def receive(self) -> AsyncIterable[dict[str, any]]:
 
     async def send(
         self,
-        content: InputEvent | ToolResultEvent,
+        content: BidiInputEvent | ToolResultEvent,
     ) -> None:
         """Unified send method for all content types. Sends the given content to Nova Sonic.
 
@@ -513,7 +513,7 @@ async def stop(self) -> None:
         finally:
             logger.debug("Nova connection closed")
 
-    def _convert_nova_event(self, nova_event: dict[str, any]) -> OutputEvent | None:
+    def _convert_nova_event(self, nova_event: dict[str, any]) -> BidiOutputEvent | None:
         """Convert Nova Sonic events to TypedEvent format."""
         # Handle completion start - track completionId
         if "completionStart" in nova_event:

src/strands/experimental/bidirectional_streaming/models/openai.py

@@ -25,10 +25,10 @@
     BidiConnectionStartEvent,
     BidiErrorEvent,
     BidiImageInputEvent,
-    InputEvent,
+    BidiInputEvent,
     BidiInterruptionEvent,
     BidiUsageEvent,
-    OutputEvent,
+    BidiOutputEvent,
     BidiTextInputEvent,
     BidiTranscriptStreamEvent,
     BidiResponseCompleteEvent,
@@ -291,7 +291,7 @@ async def _process_responses(self) -> None:
             self._active = False
             logger.debug("OpenAI Realtime response processor stopped")
 
-    async def receive(self) -> AsyncIterable[OutputEvent]:
+    async def receive(self) -> AsyncIterable[BidiOutputEvent]:
         """Receive OpenAI events and convert to Strands TypedEvent format."""
         # Emit connection start event
         yield BidiConnectionStartEvent(
@@ -315,7 +315,7 @@ async def receive(self) -> AsyncIterable[OutputEvent]:
             # Emit connection close event
             yield BidiConnectionCloseEvent(connection_id=self.connection_id, reason="complete")
 
-    def _convert_openai_event(self, openai_event: dict[str, any]) -> list[OutputEvent] | None:
+    def _convert_openai_event(self, openai_event: dict[str, any]) -> list[BidiOutputEvent] | None:
         """Convert OpenAI events to Strands TypedEvent format."""
         event_type = openai_event.get("type")
 
@@ -526,7 +526,7 @@ def _convert_openai_event(self, openai_event: dict[str, any]) -> list[OutputEven
 
     async def send(
         self,
-        content: InputEvent | ToolResultEvent,
+        content: BidiInputEvent | ToolResultEvent,
     ) -> None:
         """Unified send method for all content types. Sends the given content to OpenAI.
         

src/strands/experimental/bidirectional_streaming/types/__init__.py

@@ -14,11 +14,11 @@
     BidiConnectionStartEvent,
     BidiErrorEvent,
     BidiImageInputEvent,
-    InputEvent,
+    BidiInputEvent,
     BidiInterruptionEvent,
     ModalityUsage,
     BidiUsageEvent,
-    OutputEvent,
+    BidiOutputEvent,
     BidiResponseCompleteEvent,
     BidiResponseStartEvent,
     BidiTextInputEvent,
@@ -31,7 +31,7 @@
     "BidiTextInputEvent",
     "BidiAudioInputEvent",
     "BidiImageInputEvent",
-    "InputEvent",
+    "BidiInputEvent",
     # Output Events
     "BidiConnectionStartEvent",
     "BidiConnectionCloseEvent",
@@ -43,7 +43,7 @@
     "BidiUsageEvent",
     "ModalityUsage",
     "BidiErrorEvent",
-    "OutputEvent",
+    "BidiOutputEvent",
     # Constants
     "SUPPORTED_AUDIO_FORMATS",
     "SUPPORTED_SAMPLE_RATES",

src/strands/experimental/bidirectional_streaming/types/events.py

@@ -504,11 +504,11 @@ def details(self) -> Optional[Dict[str, Any]]:
 # ============================================================================
 
 # Note: ToolResultEvent is imported from strands.types._events and used alongside
-# InputEvent in send() methods for sending tool results back to the model.
+# BidiInputEvent in send() methods for sending tool results back to the model.
 
-InputEvent = BidiTextInputEvent | BidiAudioInputEvent | BidiImageInputEvent
+BidiInputEvent = BidiTextInputEvent | BidiAudioInputEvent | BidiImageInputEvent
 
-OutputEvent = (
+BidiOutputEvent = (
     BidiConnectionStartEvent
     | BidiResponseStartEvent
     | BidiAudioStreamEvent