fix: forward error and close for bedrock decoder (#66)

anthropics · Dec 1, 2024 · 5f6f6fd · 5f6f6fd
1 parent 9fb231b
commit 5f6f6fd
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/bedrock/bedrock.go b/bedrock/bedrock.go
@@ -46,11 +46,11 @@ type eventstreamDecoder struct {
 }
 
 func (e *eventstreamDecoder) Close() error {
-	return nil
+	return e.rc.Close()
 }
 
 func (e *eventstreamDecoder) Err() error {
-	return nil
+	return e.err
 }
 
 func (e *eventstreamDecoder) Next() bool {