Feature: Converse Streams

README.md

@@ -136,11 +136,11 @@ Prism Bedrock supports three of those API schemas:
 
 Each schema supports different capabilities:
 
-| Schema | Text | Structured | Embeddings |
-|--------|:----:|:----------:|:----------:|
-| Converse | ✅ | ✅ | ❌ |
-| Anthropic | ✅ | ✅ | ❌ |
-| Cohere | ❌ | ❌ | ✅ |
+| Schema | Text | Structured | Embeddings | Stream |
+|--------|:----:|:----------:|:----------:|:------:|
+| Converse | ✅ | ✅ | ❌ | ✅ |
+| Anthropic | ✅ | ✅ | ❌ | ❌|
+| Cohere | ❌ | ❌ | ✅ | ❌ |
 
 \* A unified interface for multiple providers. See [AWS documentation](https://docs.aws.amazon.com/bedrock/latest/userguide/conversation-inference-supported-models-features.html) for a list of supported models.
 

composer.json

@@ -22,7 +22,7 @@
     "php": "^8.2",
     "laravel/framework": "^11.0|^12.0",
     "aws/aws-sdk-php": "^3.339",
-    "prism-php/prism": ">=0.88.0"
+    "prism-php/prism": ">=0.92.0"
   },
   "config": {
     "allow-plugins": {

src/Bedrock.php

@@ -4,9 +4,11 @@
 
 use Aws\Credentials\Credentials;
 use Aws\Signature\SignatureV4;
+use Generator;
 use Illuminate\Http\Client\PendingRequest;
 use Illuminate\Http\Client\Request;
 use Prism\Bedrock\Enums\BedrockSchema;
+use Prism\Bedrock\Schemas\Converse\ConverseStreamHandler;
 use Prism\Prism\Concerns\InitializesClient;
 use Prism\Prism\Contracts\PrismRequest;
 use Prism\Prism\Embeddings\Request as EmbeddingRequest;
@@ -73,6 +75,18 @@ public function structured(StructuredRequest $request): StructuredResponse
         return $handler->handle($request);
     }
 
+    #[\Override]
+    public function stream(TextRequest $request): Generator
+    {
+        $handler = new ConverseStreamHandler($this->client(
+            $request,
+            $request->clientOptions(),
+            $request->clientRetry()
+        ));
+
+        return $handler->handle($request);
+    }
+
     #[\Override]
     public function embeddings(EmbeddingRequest $request): EmbeddingsResponse
     {