PR changes

Author: gjcairo

Sources/GRPCCore/Call/Client/ClientResponse.swift

@@ -363,7 +363,7 @@ extension StreamingClientResponse {
 
   /// Returns the messages received from the server.
   ///
-  /// For rejected RPCs the `RPCAsyncSequence` throws a `RPCError``.
+  /// For rejected RPCs (in other words, where ``accepted`` is `failure`), the `RPCAsyncSequence` throws a `RPCError``.
   public var messages: RPCAsyncSequence<Message, any Error> {
     switch self.accepted {
     case let .success(contents):
@@ -385,10 +385,16 @@ extension StreamingClientResponse {
 
   /// Returns the body parts (i.e. `messages` and `trailingMetadata`) returned from the server.
   ///
-  /// For rejected RPCs (in other words, where ``accepted`` is `failure`), this method throws an `RPCError`.
+  /// For rejected RPCs (in other words, where ``accepted`` is `failure`), the `RPCAsyncSequence` throws a `RPCError``.
   public var bodyParts: RPCAsyncSequence<Contents.BodyPart, any Error> {
-    get throws {
-      try self.accepted.get().bodyParts
+    switch self.accepted {
+    case let .success(contents):
+      return contents.bodyParts
+
+    case let .failure(error):
+      return RPCAsyncSequence.throwing(error)
     }
   }
 }
+
+extension StreamingClientResponse.Contents.BodyPart: Equatable where Message: Equatable {}

Tests/GRPCCoreTests/Call/Client/ClientResponseTests.swift

@@ -107,7 +107,7 @@ final class ClientResponseTests: XCTestCase {
       XCTAssertEqual($0, error)
     }
     await XCTAssertThrowsRPCErrorAsync {
-      try response.bodyParts
+      try await response.bodyParts.collect()
     } errorHandler: {
       XCTAssertEqual($0, error)
     }
@@ -210,21 +210,3 @@ final class ClientResponseTests: XCTestCase {
     }
   }
 }
-
-extension StreamingClientResponse.Contents.BodyPart: Equatable where Message: Equatable {
-  static func == (
-    lhs: StreamingClientResponse.Contents.BodyPart,
-    rhs: StreamingClientResponse.Contents.BodyPart
-  ) -> Bool {
-    switch (lhs, rhs) {
-    case (.message(let lhsMessage), .message(let rhsMessage)):
-      return lhsMessage == rhsMessage
-
-    case (.trailingMetadata(let lhsMetadata), .trailingMetadata(let rhsMetadata)):
-      return lhsMetadata == rhsMetadata
-
-    default:
-      return false
-    }
-  }
-}