Model interface

pyproject.toml

@@ -54,6 +54,25 @@ sagemaker = [
     "boto3-stubs[sagemaker-runtime]>=1.26.0,<2.0.0",
     "openai>=1.68.0,<2.0.0",  # SageMaker uses OpenAI-compatible interface
 ]
+bidirectional-streaming-nova = [
+    "pyaudio>=0.2.13",
+    "rx>=3.2.0",
+    "smithy-aws-core>=0.0.1",
+    "pytz",
+    "aws_sdk_bedrock_runtime",
+]
+bidirectional-streaming-openai = [
+    "pyaudio>=0.2.13",
+    "websockets>=12.0,<14.0",
+]
+bidirectional-streaming = [
+    "pyaudio>=0.2.13",
+    "rx>=3.2.0",
+    "smithy-aws-core>=0.0.1",
+    "pytz",
+    "aws_sdk_bedrock_runtime",
+    "websockets>=12.0,<14.0",
+]
 otel = ["opentelemetry-exporter-otlp-proto-http>=1.30.0,<2.0.0"]
 docs = [
     "sphinx>=5.0.0,<9.0.0",
@@ -69,7 +88,7 @@ a2a = [
     "fastapi>=0.115.12,<1.0.0",
     "starlette>=0.46.2,<1.0.0",
 ]
-all = ["strands-agents[a2a,anthropic,docs,gemini,litellm,llamaapi,mistral,ollama,openai,writer,sagemaker,otel]"]
+all = ["strands-agents[a2a,anthropic,docs,gemini,bidirectional-streaming,docs,litellm,llamaapi,mistral,ollama,openai,writer,sagemaker,otel]"]
 
 dev = [
     "commitizen>=4.4.0,<5.0.0",

src/strands/experimental/bidirectional_streaming/__init__.py

@@ -0,0 +1,44 @@
+"""Bidirectional streaming package."""
+
+# Main components - Primary user interface
+from .agent.agent import BidirectionalAgent
+
+# Advanced interfaces (for custom implementations)
+from .models.base_model import BidirectionalModel, BidirectionalModelSession
+
+# Model providers - What users need to create models
+from .models.novasonic import NovaSonicBidirectionalModel
+from .models.openai import OpenAIRealtimeBidirectionalModel
+
+# Event types - For type hints and event handling
+from .types.bidirectional_streaming import (
+    AudioInputEvent,
+    AudioOutputEvent,
+    BidirectionalStreamEvent,
+    InterruptionDetectedEvent,
+    TextOutputEvent,
+    UsageMetricsEvent,
+    VoiceActivityEvent,
+)
+
+__all__ = [
+    # Main interface
+    "BidirectionalAgent",
+
+    # Model providers
+    "NovaSonicBidirectionalModel",
+    "OpenAIRealtimeBidirectionalModel",
+
+    # Event types
+    "AudioInputEvent",
+    "AudioOutputEvent", 
+    "TextOutputEvent",
+    "InterruptionDetectedEvent",
+    "BidirectionalStreamEvent",
+    "VoiceActivityEvent",
+    "UsageMetricsEvent",
+
+    # Model interface
+    "BidirectionalModel",
+    "BidirectionalModelSession",
+]

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

@@ -0,0 +1,5 @@
+"""Bidirectional agent for real-time streaming conversations."""
+
+from .agent import BidirectionalAgent
+
+__all__ = ["BidirectionalAgent"]