fix tests

Author: grdsdev

Sources/Realtime/Deprecated/Deprecated.swift

@@ -95,9 +95,10 @@ extension RealtimeChannelV2 {
   @_disfavoredOverload
   @available(*, deprecated, message: "Use `broadcastStream(event:)` with `BroadcastEvent` instead.")
   public func broadcastStream(event: String) -> AsyncStream<JSONObject> {
-    self.broadcastStream(event: event).map { (payload: BroadcastEvent) in
+    let stream = self.broadcastStream(event: event).map { (payload: BroadcastEvent) in
       try! JSONObject(payload)
     }
-    .eraseToStream()
+
+    return AsyncStream(stream)
   }
 }

Sources/Realtime/RealtimeChannel+AsyncAwait.swift

@@ -192,7 +192,7 @@ extension RealtimeChannelV2 {
 }
 
 // Helper to work around type ambiguity in macOS 13
-fileprivate extension AsyncStream<AnyAction> {
+extension AsyncStream<AnyAction> {
   func compactErase<T: Sendable>() -> AsyncStream<T> {
     AsyncStream<T>(compactMap { $0.wrappedAction as? T } as AsyncCompactMapSequence<Self, T>)
   }

Sources/Realtime/Types.swift

@@ -112,7 +112,7 @@ public enum LogLevel: String, Sendable {
 ///
 /// If broadcast event was triggered using [`realtime.broadcast_changes`](https://supabase.com/docs/guides/realtime/subscribing-to-database-changes#using-broadcast),
 /// use ``BroadcastEvent/broadcastChange(of:)`` to decode the payload into a specific type.
-public struct BroadcastEvent: Codable, Sendable {
+public struct BroadcastEvent: Codable, Hashable, Sendable {
   /// The type of the event, e.g. `broadcast`.
   public let type: String
   /// The event that triggered the broadcast.

Tests/RealtimeTests/CallbackManagerTests.swift

@@ -178,24 +178,20 @@ final class CallbackManagerTests: XCTestCase {
     XCTAssertNoLeak(callbackManager)
 
     let event = "new_user"
-    let message = RealtimeMessageV2(
-      joinRef: nil,
-      ref: nil,
-      topic: "realtime:users",
+    let message = BroadcastEvent(
+      type: "broadcast",
       event: event,
       payload: ["email": "[email protected]"]
     )
 
-    let jsonObject = try JSONObject(message)
-
-    let receivedMessage = LockIsolated<JSONObject?>(nil)
+    let receivedMessage = LockIsolated<BroadcastEvent?>(nil)
     callbackManager.addBroadcastCallback(event: event) {
       receivedMessage.setValue($0)
     }
 
-    callbackManager.triggerBroadcast(event: event, json: jsonObject)
+    callbackManager.triggerBroadcast(event: event, json: message)
 
-    XCTAssertEqual(receivedMessage.value, jsonObject)
+    XCTAssertEqual(receivedMessage.value, message)
   }
 
   func testTriggerPresenceDiffs() {