File tree Expand file tree Collapse file tree
src/strands/experimental/bidirectional_streaming/agent Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2727from ....types .content import Message , Messages
2828from ....types .tools import ToolResult , ToolUse , AgentTool
2929
30- from ..event_loop .bidirectional_event_loop import BidiAgentLoop
30+ from ..event_loop .bidirectional_event_loop import BidirectionalConnection
3131from ..models .bidirectional_model import BidiModel
3232from ..models .novasonic import BidiNovaSonicModel
3333from ..types .bidirectional_streaming import AudioInputEvent , BidirectionalStreamEvent , ImageInputEvent
@@ -121,7 +121,7 @@ def __init__(
121121 self ._tool_caller = _ToolCaller (self )
122122
123123 # connection management
124- self ._agent_loop : "BidiAgentLoop " | None = None
124+ self ._agent_loop : "BidirectionalConnection " | None = None
125125 self ._output_queue = asyncio .Queue ()
126126 self ._current_adapters = [] # Track adapters for cleanup
127127
@@ -256,7 +256,7 @@ async def start(self) -> None:
256256 system_prompt = self .system_prompt , tools = self .tool_registry .get_all_tool_specs (), messages = self .messages
257257 )
258258
259- self ._agent_loop = BidiAgentLoop (model = self .model , agent = self )
259+ self ._agent_loop = BidirectionalConnection (model = self .model , agent = self )
260260 await self ._agent_loop .start ()
261261
262262 logger .debug ("Conversation ready" )
You can’t perform that action at this time.
0 commit comments